Re: Elasticsearch 5.x connection

2017-03-02 Thread Tzu-Li (Gordon) Tai
Hi, java.lang.NoSuchMethodError: org.apache.flink.util.InstantiationUtil.isSerializable(Ljava/lang/Object;)Z         at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.(ElasticsearchSinkBase.java:195)         at

Elasticsearch 5.x connection

2017-03-02 Thread Fábio Dias
Hi, Last Friday I was running elasticsearch 5.X with Flink 1.2.0 In the pom.xml I added this dependency: org.apache.flink flink-connector-elasticsearch-base_2.10 1.3-SNAPSHOT org.elasticsearch elasticsearch And I added to two files : the ElasticsearchSink.java and