Re: ClassNotFoundException: org.apache.kafka.common.metrics.stats.Rate$1

2018-11-20 Thread Stefan Richter
Hi, It should be as easy as making sure that there is a jar with the missing class in the class path of your user-code class loader. Best, Stefan > On 20. Nov 2018, at 14:32, Avi Levi wrote: > > looking at the log file of the taskexecutor I see this exception > at

ClassNotFoundException: org.apache.kafka.common.metrics.stats.Rate$1

2018-11-20 Thread Avi Levi
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