org.apache.samza.system.SystemConsumersException: Cannot >> >>>deserialize an incoming message. at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:2 >> >>>>>93) at org.apache.samza.system.SystemConsumers.org >> >>>$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:260) at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(Syste >> >>>>>mCo nsumers.scala:276) at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(Syste >> >>>>>mCo nsumers.scala:276) at >> >>> >> >>> >> >> >>>>>scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike. >> >>>>>sca la:244) at >> >>> >> >>> >> >> >>>>>scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike. >> >>>>>sca la:244)

samza-dev | Ash W Matheson | 2 years ago
  1. 0

    Re: New to Samza/Yarn and having Kafka issues

    samza-dev | 2 years ago | Ash W Matheson
    org.apache.samza.system.SystemConsumersException: Cannot >> >>>deserialize an incoming message. at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:2 >> >>>>>93) at org.apache.samza.system.SystemConsumers.org >> >>>$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:260) at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(Syste >> >>>>>mCo nsumers.scala:276) at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(Syste >> >>>>>mCo nsumers.scala:276) at >> >>> >> >>> >> >> >>>>>scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike. >> >>>>>sca la:244) at >> >>> >> >>> >> >> >>>>>scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike. >> >>>>>sca la:244)

    Root Cause Analysis

    1. org.apache.samza.system.SystemConsumersException

      Cannot >> >>>deserialize an incoming message. at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:2 >> >>>>>93) at org.apache.samza.system.SystemConsumers.org >> >>>$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:260) at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(Syste >> >>>>>mCo nsumers.scala:276) at >> >>> >> >>> >> >> >>>>>org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(Syste >> >>>>>mCo nsumers.scala:276) at >> >>> >> >>> >> >> >>>>>scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike. >> >>>>>sca la:244) at >> >>> >> >>> >> >> >>>>>scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike. >> >>>>>sca la:244)

      at scala.collection.Iterator$class.foreach()
    2. Scala
      Iterator$class.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:727)
      1 frame