Stephan Ewen created FLINK-7150: ----------------------------------- Summary: Code improvements to the ElasticSearch connector Key: FLINK-7150 URL: https://issues.apache.org/jira/browse/FLINK-7150 Project: Flink Issue Type: Improvement Components: ElasticSearch Connector Affects Versions: 1.3.1 Reporter: Stephan Ewen Assignee: Stephan Ewen Fix For: 1.4.0
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}} -- This message was sent by Atlassian JIRA (v6.4.14#64029)