flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Guava version conflict
Date Wed, 07 Jun 2017 14:11:34 GMT
Hi to all,
I'm trying to use the new ES connector to index data from Flink (with ES
2.4.1).
When I try to run it from Eclipse everything is ok, when I run it from the
cluster I get the following exception:

java.lang.NoSuchMethodError: com.google.common.util.
concurrent.MoreExecutors.directExecutor()Ljava/util/concurrent/Executor;
        at org.elasticsearch.threadpool.ThreadPool.<clinit>(
ThreadPool.java:192)
        at org.elasticsearch.client.transport.TransportClient$
Builder.build(TransportClient.java:131)

In my fat jar there are the classes of guava 18 (ES requires that version),
Flink runs on CDH 5.9 (that use guava 11), in flink-dist jar I think that
there's guava 11 classes while in flink-hadoop-compatibility there are
shade guava 18 dependencies.

How can I make the job successfully run on the cluster?

Best,
Flavio

Mime
View raw message