Github user fpompermaier commented on the pull request:
https://github.com/apache/flink/commit/b5caaef82add4a6f424094d526700c77b011724e#commitcomment-27100256
In
flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java:
In
flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java
on line 63:
Why these settings here...? I've drafted a connector for es 5.6.5 and I
removed these 2 lines..but then I have to set
es.set.netty.runtime.available.processors=false otherwise there's an Exception
related to a concurrent call to
NettyRuntime$AvailableProcessorsHolder.setAvailableProcessors()...Moreover,
this exception cannot be reproduced in a Local cluster (i.e. while debugging
from the IDE) but it happens only on the cluster when a TaskManager use
multiple slots simultaneoulsy
---
