Skip to content

Instantly share code, notes, and snippets.

@tdavis

tdavis/gist:3398dc66fecb948eca53af0142a0c331 Secret

Created February 5, 2018 04:18
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save tdavis/3398dc66fecb948eca53af0142a0c331 to your computer and use it in GitHub Desktop.
Save tdavis/3398dc66fecb948eca53af0142a0c331 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
example-2 example 2018-02-05 04:12:57,903 [p-21fa20af-5ffb-4e6e-8d37-c405e6a43a2a-container-thread-0] ERROR org.apache.samza.container.SamzaContainer - Caught exception/error in run loop.
example-2 example org.apache.samza.system.SystemConsumersException: Cannot deserialize an incoming message for SystemStream [system=kafka, stream=explode-output]
example-2 example at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:343)
example-2 example at org.apache.samza.system.SystemConsumers.tryUpdate(SystemConsumers.scala:311)
example-2 example at org.apache.samza.system.SystemConsumers.org$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:299)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$SystemConsumers$$refresh$2.apply(SystemConsumers.scala:326)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$SystemConsumers$$refresh$2.apply(SystemConsumers.scala:326)
example-2 example at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
example-2 example at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
example-2 example at scala.collection.Iterator$class.foreach(Iterator.scala:893)
example-2 example at scala.collection.AbstractIterator.foreach(Iterator.scala:1336)
example-2 example at scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:174)
example-2 example at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
example-2 example at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47)
example-2 example at scala.collection.SetLike$class.map(SetLike.scala:92)
example-2 example at scala.collection.AbstractSet.map(Set.scala:47)
example-2 example at org.apache.samza.system.SystemConsumers.org$apache$samza$system$SystemConsumers$$refresh(SystemConsumers.scala:326)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$choose$2.apply$mcV$sp(SystemConsumers.scala:244)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$choose$2.apply(SystemConsumers.scala:243)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$choose$2.apply(SystemConsumers.scala:243)
example-2 example at org.apache.samza.util.TimerUtils$class.updateTimer(TimerUtils.scala:37)
example-2 example at org.apache.samza.system.SystemConsumers.updateTimer(SystemConsumers.scala:51)
example-2 example at org.apache.samza.system.SystemConsumers.choose(SystemConsumers.scala:242)
example-2 example at org.apache.samza.task.AsyncRunLoop.chooseEnvelope(AsyncRunLoop.java:204)
example-2 example at org.apache.samza.task.AsyncRunLoop.run(AsyncRunLoop.java:152)
example-2 example at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:728)
example-2 example at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
example-2 example at java.util.concurrent.FutureTask.run(FutureTask.java:266)
example-2 example at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
example-2 example at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
example-2 example at java.lang.Thread.run(Thread.java:748)
example-2 example Caused by: java.nio.BufferUnderflowException
example-2 example at java.nio.Buffer.nextGetIndex(Buffer.java:506)
example-2 example at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:361)
example-2 example at org.apache.samza.serializers.IntegerSerde.fromBytes(IntegerSerde.java:40)
example-2 example at org.apache.samza.serializers.IntegerSerde.fromBytes(IntegerSerde.java:27)
example-2 example at org.apache.samza.serializers.SerdeManager.fromBytes(SerdeManager.scala:118)
example-2 example at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:340)
example-2 example ... 28 more
example-2 example 2018-02-05 04:12:58,302 [p-21fa20af-5ffb-4e6e-8d37-c405e6a43a2a-container-thread-0] ERROR org.apache.samza.processor.StreamProcessor - Container failed. Stopping the processor.
example-2 example org.apache.samza.system.SystemConsumersException: Cannot deserialize an incoming message for SystemStream [system=kafka, stream=explode-output]
example-2 example at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:343)
example-2 example at org.apache.samza.system.SystemConsumers.tryUpdate(SystemConsumers.scala:311)
example-2 example at org.apache.samza.system.SystemConsumers.org$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:299)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$SystemConsumers$$refresh$2.apply(SystemConsumers.scala:326)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$SystemConsumers$$refresh$2.apply(SystemConsumers.scala:326)
example-2 example at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
example-2 example at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
example-2 example at scala.collection.Iterator$class.foreach(Iterator.scala:893)
example-2 example at scala.collection.AbstractIterator.foreach(Iterator.scala:1336)
example-2 example at scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:174)
example-2 example at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
example-2 example at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47)
example-2 example at scala.collection.SetLike$class.map(SetLike.scala:92)
example-2 example at scala.collection.AbstractSet.map(Set.scala:47)
example-2 example at org.apache.samza.system.SystemConsumers.org$apache$samza$system$SystemConsumers$$refresh(SystemConsumers.scala:326)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$choose$2.apply$mcV$sp(SystemConsumers.scala:244)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$choose$2.apply(SystemConsumers.scala:243)
example-2 example at org.apache.samza.system.SystemConsumers$$anonfun$choose$2.apply(SystemConsumers.scala:243)
example-2 example at org.apache.samza.util.TimerUtils$class.updateTimer(TimerUtils.scala:37)
example-2 example at org.apache.samza.system.SystemConsumers.updateTimer(SystemConsumers.scala:51)
example-2 example at org.apache.samza.system.SystemConsumers.choose(SystemConsumers.scala:242)
example-2 example at org.apache.samza.task.AsyncRunLoop.chooseEnvelope(AsyncRunLoop.java:204)
example-2 example at org.apache.samza.task.AsyncRunLoop.run(AsyncRunLoop.java:152)
example-2 example at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:728)
example-2 example at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
example-2 example at java.util.concurrent.FutureTask.run(FutureTask.java:266)
example-2 example at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
example-2 example at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
example-2 example at java.lang.Thread.run(Thread.java:748)
example-2 example Caused by: java.nio.BufferUnderflowException
example-2 example at java.nio.Buffer.nextGetIndex(Buffer.java:506)
example-2 example at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:361)
example-2 example at org.apache.samza.serializers.IntegerSerde.fromBytes(IntegerSerde.java:40)
example-2 example at org.apache.samza.serializers.IntegerSerde.fromBytes(IntegerSerde.java:27)
example-2 example at org.apache.samza.serializers.SerdeManager.fromBytes(SerdeManager.scala:118)
example-2 example at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:340)
example-2 example ... 28 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment