flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: cannot use ElasticsearchSink in Flink1.3.0
Date Thu, 20 Jul 2017 07:33:07 GMT

There was an issue with release ES 5 in 1.3.0, and the artifacts were not released to Maven
Please use 1.3.1 instead.


On 20 July 2017 at 3:31:39 PM, ZalaCheung (gzzhangdesheng@corp.netease.com) wrote:

Hi all,

I am using Flink 1.3.0 and following instructions here to add elasticsearch as a sink.


I follow the instruction to add the dependency like this:

the flink version is 1.3.0.

When I try to write code to add es as sink, IntelliJ cannot resolve symbol for “ElasticsearchSink”.

result.addSink(new ElasticsearchSink<>(config, transportAddresses, new ElasticsearchSinkFunction<String>(){
    public IndexRequest createIndexRequest(String element){


    public void process(String element, RuntimeContext ctx, RequestIndexer indexer) {


The elastic package doesn’t contain anything called “ElasticsearchSink”, only has “ElasticserachSinkFunciton”

import org.apache.flink.streaming.connectors.elasticsearch.

Desheng Zhang
E-mail: gzzhangdesheng@corp.netease.com;

View raw message