flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fpompermaier <...@git.apache.org>
Subject [GitHub] flink pull request #:
Date Thu, 25 Jan 2018 13:57:19 GMT
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


---

Mime
View raw message