Details
-
Bug
-
Resolution: Done
-
Minor
-
1.9.0.Alpha2
-
None
-
False
-
False
Description
Elastic search sink connector fails in jpa-aggregations example with exception
connect_1 | [io.confluent.connect.elasticsearch.ElasticsearchSinkConnectorConfig]
connect_1 | 2022-02-23 13:08:08,378 ERROR || WorkerSinkTask\{id=es-customers-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask]
connect_1 | java.lang.NoClassDefFoundError: com/google/common/collect/ImmutableSet
connect_1 | at io.searchbox.client.AbstractJestClient.<init>(AbstractJestClient.java:33)
connect_1 | at io.searchbox.client.http.JestHttpClient.<init>(JestHttpClient.java:32)
connect_1 | at io.searchbox.client.JestClientFactory.getObject(JestClientFactory.java:44)
connect_1 | at io.confluent.connect.elasticsearch.jest.JestElasticsearchClient.<init>(JestElasticsearchClient.java:144)
connect_1 | at io.confluent.connect.elasticsearch.jest.JestElasticsearchClient.<init>(JestElasticsearchClient.java:114)
connect_1 | at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:120)
connect_1 | at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:51)
connect_1 | at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:312)
connect_1 | at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
connect_1 | at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:243)
connect_1 | at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
connect_1 | at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
connect_1 | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
connect_1 | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
connect_1 | at java.base/java.lang.Thread.run(Thread.java:829)
connect_1 | Caused by: java.lang.ClassNotFoundException: com.google.common.collect.ImmutableSet
connect_1 | at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:476)
connect_1 | at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:589)
connect_1 | at org.apache.kafka.connect.runtime.isolation.PluginClassLoader.loadClass(PluginClassLoader.java:103)
connect_1 | at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:522)
connect_1 | ... 15 more
It's due to missing guava dependency, adding
curl -sO https://repo1.maven.org/maven2/com/google/guava/guava/31.0.1-jre/guava-31.0.1-jre.jar
into json-smt-es/Dockerfile fixes this issue, but Elastic still fails
"reason" : "all shards failed"
so there are probably more issue.
