[FLINK-7150] Code improvements to the ElasticSearch connector

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.1
• Fix Version/s: 1.4.0
• Component/s: Connectors / ElasticSearch
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 11/Jul/17 11:05
• Updated: 08/Nov/17 13:32
• Resolved: 08/Nov/17 13:32

Description

I suggest some improvements to the handling of generic types, inner classes, and serializability:

• Remove Serializable from the RequestIndexer, because they are neither required to be serializable (they are created in open()) nor is the main implementation (BulkProcessorIndexer) actually serializable.

• Make BulkFlushBackoffPolicy a static inner class, which avoids adding outer class during serialization and clears various warnings about raw reference to outer class

• Fixe various raw generic type warnings for the use of ActionRequest

Issue Links

• links to: GitHub Pull Request #4298