I've found out the source of the problem when I build flink locally. elastic-search base depends on (by default) ES version 1.7.1 that depends on asm 4.1 and that version is shaded to elasticsearch-base-jar. I tried to set elasticsearch.version property in Maven to 5.1.2 (the same as elasticsearch5 connector) but then elasticsearch-base does not compile:
[ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.1:testCompile (default-testCompile) on project flink-connector-elasticsearch-base_2.11: Compilation failure [ERROR] /home/adebski/Downloads/flink-release-1.3.1/flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java:[491,92] no suitable constructor found for BulkItemResponse(int,java.lang.String,org.elasticsearch.action.ActionResponse) [ERROR] constructor org.elasticsearch.action.bulk.BulkItemResponse.BulkItemResponse(int,java.lang.String,org.elasticsearch.action.DocWriteResponse) is not applicable [ERROR] (argument mismatch; org.elasticsearch.action.ActionResponse cannot be converted to org.elasticsearch.action.DocWriteResponse) [ERROR] constructor org.elasticsearch.action.bulk.BulkItemResponse.BulkItemResponse(int,java.lang.String,org.elasticsearch.action.bulk.BulkItemResponse.Failure) is not applicable [ERROR] (argument mismatch; org.elasticsearch.action.ActionResponse cannot be converted to org.elasticsearch.action.bulk.BulkItemResponse.Failure) -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/elastic-search-connector-for-1-3-1-not-working-for-local-environemnt-tp14140p14141.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
