flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Avi Levi <avi.l...@bluevoyant.com>
Subject ClassNotFoundException: org.apache.kafka.common.metrics.stats.Rate$1
Date Tue, 20 Nov 2018 13:32:56 GMT
looking at the log file of the taskexecutor I see this exception








*at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)Caused
by: java.lang.ClassNotFoundException:
org.apache.kafka.common.metrics.stats.Rate$1at
java.net.URLClassLoader.findClass(URLClassLoader.java:382)at
java.lang.ClassLoader.loadClass(ClassLoader.java:424)at
org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader.loadClass(FlinkUserCodeClassLoaders.java:129)at
java.lang.ClassLoader.loadClass(ClassLoader.java:357)*
... 22 more
anyone know what should I do to avoid it ?

Mime
View raw message