samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jeremiah Adams <JAd...@helixeducation.com.INVALID>
Subject Nullpointer After Upgrade from samza 1.0.0 to 1.3.0
Date Wed, 15 Jan 2020 17:41:24 GMT
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>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message