Hi Martin,
>From a quick look into the source code, it seems like the nodes are
not necessarily available after the TransportClient has been created.
The sampling may take several attempts and the check immediately after
the first try is a bit restrictive.
Nevertheless, if this happens consistent
Hi everyone,
I'm trying to connect my flink streaming job to elastic search but I have
trouble to make it work.
Here is the config I'm using for the connector:
HashMap elConf = new HashMap<>();
elConf.put("bulk.flush.max.actions", "1");
elConf.put("cluster.name", "logelask");
List transports = ne
