-
Type:
Bug
-
Resolution: Done
-
Priority:
Major - P3
-
None
-
Affects Version/s: None
-
Component/s: Source
-
None
-
None
-
None
-
None
-
None
-
None
-
None
-
None
java.lang.NullPointerExceptionjava.lang.NullPointerException at com.mongodb.kafka.connect.source.MongoSourceTask.poll(MongoSourceTask.java:213) at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:272) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:239) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:184) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234) 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)
I guess it's because heartbeatManager not creating in com.mongodb.kafka.connect.source.MongoSourceTask#start if shouldCopyData()=true.
So, in such case heartbeatManager.heartbeat() could be called when heartbeatManager not created yet.
Found this error in the last master.