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_authentication.html Cheers, Till On Thu, Nov 22, 2018 at 9:36 AM hzyuemeng1 <hzyueme...@corp.netease.com> wrote: > > after i install x-pack in my elasticsearch cluster and the elasticsearch > cluster with basicauth > the elasticsearch sink can't connect to elastic cluster > > code like： > > DataStream<Tuple2<Boolean, Row>> esSink27 = > tableEnv13.toRetractStream(esTable26, Row.class).filter( tuple -> tuple.f0); > //generate user config map > java.util.Map<String, String> userConfigMap22 = > com.google.common.collect.Maps.newHashMap(); > userConfigMap22.put("cluster.name", "test-magina"); > userConfigMap22.put("bulk.flush.max.actions", "1"); > //userConfigMap22.put("shield.user", "elastic:magina1001password"); > > //generate transports list > Splitter commaSplitter24 = Splitter.on(","); > Splitter colonSplitter25 = Splitter.on(":"); > List<InetSocketAddress> transportsList23 = Lists.newArrayList(); > for (String transport : commaSplitter24.split("101.206.91.118:9300")) { > List<String> ipAndPort = colonSplitter25.splitToList(transport); > transportsList23.add(new > InetSocketAddress(InetAddress.getByName(ipAndPort.get(0)), > Integer.parseInt(ipAndPort.get(1)))); > } > esSink27.addSink(new ElasticsearchSink<Tuple2<Boolean, > Row>>(userConfigMap22, transportsList23, new > MaginaES5SinkFunction(esTable26.getSchema().getColumnNames(), "userid", > "test-au", "test-au", "action,num"), new > RetryRejectedExecutionFailureHandler())).name("elasticsearch_4068").setParallelism(2); > > > - > > Any help will be greatly appreciated > > > hzyuemeng1 > hzyueme...@corp.netease.com > > <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?&name=hzyuemeng1&uid=hzyuemeng1%40corp.netease.com&ftlId=1&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fqiyelogo%2FdefaultAvatar.png&items=%5B%22hzyuemeng1%40corp.netease.com%22%5D&logoUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fqiyeicon%2F209a2912f40f6683af56bb7caff1cb54.png> > 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制 >
