Re: elasticsearch sink can't connect to elastic cluster with BasicAuth

2018-11-22 Thread Till Rohrmann
Hi, I think you need to a custom `RestClientFactory` which enables basic auth on the ElasticSearch RestClient according to this documentation [1]. You can set the RestClientFactory on the ElasticsearchSink.Builder. [1] https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/_basic_

elasticsearch sink can't connect to elastic cluster with BasicAuth

2018-11-22 Thread hzyuemeng1
after i install x-pack in my elasticsearch cluster and the elasticsearch cluster with basicauth the elasticsearch sink can't connect to elastic clustercode likeļ¼šDataStream> esSink27 = tableEnv13.toRetractStream(esTable26, Row.class).filter( tuple -> tuple.f0);//generate u