I am updating our jobs to use samza 1.3.0. I'm getting a null pointer when
manually committing via taskCoordinator.commit().
Below is the stack trace - can anyone point me in the right direction?
Thanks.
2020-01-15 10:33:35 RunLoop [ERROR] Task Partition 0 commit failed
java.lang.NullPointerException
at
scala.collection.mutable.ArrayOps$ofRef$.newBuilder$extension(ArrayOps.scala:190)
at scala.collection.mutable.ArrayOps$ofRef.newBuilder(ArrayOps.scala:186)
at
scala.collection.TraversableLike$class.filterImpl(TraversableLike.scala:246)
at scala.collection.TraversableLike$class.filter(TraversableLike.scala:259)
at scala.collection.mutable.ArrayOps$ofRef.filter(ArrayOps.scala:186)
at
org.apache.samza.storage.TransactionalStateTaskStorageManager$$anonfun$removeOldCheckpoints$2.apply(TransactionalStateTaskStorageManager.scala:94)
at
org.apache.samza.storage.TransactionalStateTaskStorageManager$$anonfun$removeOldCheckpoints$2.apply(TransactionalStateTaskStorageManager.scala:86)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
at
org.apache.samza.storage.TransactionalStateTaskStorageManager.removeOldCheckpoints(TransactionalStateTaskStorageManager.scala:86)
at org.apache.samza.container.TaskInstance.commit(TaskInstance.scala:277)
at
org.apache.samza.container.RunLoop$AsyncTaskWorker$5.run(RunLoop.java:547)
at
org.apache.samza.container.RunLoop$AsyncTaskWorker.commit(RunLoop.java:566)
at org.apache.samza.container.RunLoop$AsyncTaskWorker.run(RunLoop.java:432)
at
org.apache.samza.container.RunLoop$AsyncTaskWorker.access$300(RunLoop.java:357)
at org.apache.samza.container.RunLoop.runTasks(RunLoop.java:244)
at org.apache.samza.container.RunLoop.run(RunLoop.java:176)
at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:768)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
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)
2020-01-15 10:33:35 RunLoop [ERROR] Caught throwable and stopping run loop
java.lang.NullPointerException
at
scala.collection.mutable.ArrayOps$ofRef$.newBuilder$extension(ArrayOps.scala:190)
at scala.collection.mutable.ArrayOps$ofRef.newBuilder(ArrayOps.scala:186)
at
scala.collection.TraversableLike$class.filterImpl(TraversableLike.scala:246)
at scala.collection.TraversableLike$class.filter(TraversableLike.scala:259)
at scala.collection.mutable.ArrayOps$ofRef.filter(ArrayOps.scala:186)
at
org.apache.samza.storage.TransactionalStateTaskStorageManager$$anonfun$removeOldCheckpoints$2.apply(TransactionalStateTaskStorageManager.scala:94)
at
org.apache.samza.storage.TransactionalStateTaskStorageManager$$anonfun$removeOldCheckpoints$2.apply(TransactionalStateTaskStorageManager.scala:86)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
at
org.apache.samza.storage.TransactionalStateTaskStorageManager.removeOldCheckpoints(TransactionalStateTaskStorageManager.scala:86)
at org.apache.samza.container.TaskInstance.commit(TaskInstance.scala:277)
at
org.apache.samza.container.RunLoop$AsyncTaskWorker$5.run(RunLoop.java:547)
at
org.apache.samza.container.RunLoop$AsyncTaskWorker.commit(RunLoop.java:566)
at org.apache.samza.container.RunLoop$AsyncTaskWorker.run(RunLoop.java:432)
at
org.apache.samza.container.RunLoop$AsyncTaskWorker.access$300(RunLoop.java:357)
at org.apache.samza.container.RunLoop.runTasks(RunLoop.java:244)
at org.apache.samza.container.RunLoop.run(RunLoop.java:176)
at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:768)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
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)
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>
