Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Not A Problem
-
1.2.0
-
None
-
None
-
Latest SNAPSHOT
Description
When write a user function try to write to elastic search (depend on elasticsearch 2.3.5)
Stack like:
java.lang.NoSuchMethodError: com.google.common.util.concurrent.MoreExecutors.directExecutor()Ljava/util/concurrent/Executor;
at org.elasticsearch.threadpool.ThreadPool.<clinit>(ThreadPool.java:190)
at org.elasticsearch.client.transport.TransportClient$Builder.build(TransportClient.java:131)
at io.sherlock.capabilities.es.AbstractEsSink.open(AbstractEsSink.java:98)
When enable env.java.opts.taskmanager to -version:class, we can see the class load log like:
[Loaded com.google.common.util.concurrent.MoreExecutors from file:/opt/flink/lib/flink-dist_2.11-1.2.0.jar]
The user code is using guva of 18.0.
Attachments
Issue Links
- is a clone of
-
FLINK-4587 Yet another java.lang.NoSuchFieldError: INSTANCE
- Resolved