I am updating dependencies and moving from Samza V0.13.0 to V0.14.0. I develop
locally using the grid app in the hello-samza project to spin up local
yarn/zookeeper/kafka instances.
Grid is running these versions:
kafka_2.11-0.10.2.1.tgz
hadoop-2.6.1.tar.gz
zookeeper-3.4.3.tar.gz
My job is now failing with the NPE below. anyone have ideas on the cause of
this error?
2019-03-04 14:13:49 AsyncRunLoop [ERROR] Task Partition 0 commit failed
java.lang.NullPointerException
at
com.google.common.base.Preconditions.checkNotNull(Preconditions.java:782)
at
org.apache.samza.checkpoint.kafka.KafkaCheckpointLogKey.<init>(KafkaCheckpointLogKey.java:46)
at
org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.writeCheckpoint(KafkaCheckpointManager.scala:136)
at
org.apache.samza.checkpoint.OffsetManager.writeCheckpoint(OffsetManager.scala:259)
at
org.apache.samza.container.TaskInstance.commit(TaskInstance.scala:205)
at
org.apache.samza.task.AsyncRunLoop$AsyncTaskWorker$5.run(AsyncRunLoop.java:494)
at
org.apache.samza.task.AsyncRunLoop$AsyncTaskWorker.commit(AsyncRunLoop.java:513)
at
org.apache.samza.task.AsyncRunLoop$AsyncTaskWorker.run(AsyncRunLoop.java:379)
at
org.apache.samza.task.AsyncRunLoop$AsyncTaskWorker.access$300(AsyncRunLoop.java:314)
at org.apache.samza.task.AsyncRunLoop.runTasks(AsyncRunLoop.java:228)
at org.apache.samza.task.AsyncRunLoop.run(AsyncRunLoop.java:157)
at
org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:728)
at
org.apache.samza.runtime.LocalContainerRunner.run(LocalContainerRunner.java:102)
at
org.apache.samza.runtime.LocalContainerRunner.main(LocalContainerRunner.java:147)
2019-03-04 14:13:49 AsyncRunLoop [ERROR] Caught throwable and stopping run loop
Jeremiah Adams
Software Engineer
www.helixeducation.com<http://www.helixeducation.com/>
Blog<http://www.helixeducation.com/blog/> |
Twitter<https://twitter.com/HelixEducation> |
Facebook<https://www.facebook.com/HelixEducation> |
LinkedIn<http://www.linkedin.com/company/3609946>
