Kafka HDFS Connector Исключение нулевого указателя Java - PullRequest
Новая
       47

Kafka HDFS Connector Исключение нулевого указателя Java

0 голосов
/ 26 апреля 2018

Я пытаюсь подключить мой Kafka к HDFS, но при запуске конфигурации я получаю следующую ошибку: 

java.lang.NullPointerException
at io.confluent.connect.hdfs.HdfsSinkTask.close(HdfsSinkTask.java:121)
at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:339)
at org.apache.kafka.connect.runtime.WorkerSinkTask.closePartitions(WorkerSinkTask.java:513)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:154)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:146)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:190)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

Я запускаю задачу в веб-интерфейсе Landoop:

UI Screenshot

Кто-нибудь знает, откуда могла быть эта ошибка? Спасибо

...