[
https://issues.apache.org/jira/browse/SAMZA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837991#comment-16837991
]
AndyChau commented on SAMZA-2190:
---------------------------------
already settle
beacuse test kafka, use producer to try, random click the code test. and than,
the samza init check the offset have code is 'a'.
clear kafka log and restart kafka can be settle this problem.
> Cannot deserialize an incoming message
> --------------------------------------
>
> Key: SAMZA-2190
> URL: https://issues.apache.org/jira/browse/SAMZA-2190
> Project: Samza
> Issue Type: Bug
> Components: hello-samza
> Affects Versions: 0.9.0
> Environment: haddop:2.7.1
> samza:0.9
> Reporter: AndyChau
> Priority: Critical
>
> look for the record，have one error about Cannot deserialize an incoming
> message.
> How to solve this problem.
>
>
> 2019-05-12 11:58:19 SamzaContainer [ERROR] Caught exception in process loop.
> org.apache.samza.system.SystemConsumersException: Cannot deserialize an
> incoming message.
> at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:303)
> at
> org.apache.samza.system.SystemConsumers.tryUpdate(SystemConsumers.scala:270)
> at
> org.apache.samza.system.SystemConsumers.org$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:258)
> at
> org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(SystemConsumers.scala:286)
> at
> org.apache.samza.system.SystemConsumers$$anonfun$refresh$2.apply(SystemConsumers.scala:286)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> at scala.collection.Iterator$class.foreach(Iterator.scala:727)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
> at scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:174)
> at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
> at
> scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47)
> at scala.collection.SetLike$class.map(SetLike.scala:93)
> at scala.collection.AbstractSet.map(Set.scala:47)
> at org.apache.samza.system.SystemConsumers.refresh(SystemConsumers.scala:286)
> at org.apache.samza.system.SystemConsumers.choose(SystemConsumers.scala:211)
> at
> org.apache.samza.container.RunLoop$$anonfun$process$2$$anonfun$2.apply(RunLoop.scala:100)
> at
> org.apache.samza.container.RunLoop$$anonfun$process$2$$anonfun$2.apply(RunLoop.scala:100)
> at org.apache.samza.util.TimerUtils$class.updateTimer(TimerUtils.scala:37)
> at org.apache.samza.container.RunLoop.updateTimer(RunLoop.scala:36)
> at
> org.apache.samza.container.RunLoop$$anonfun$process$2.apply(RunLoop.scala:99)
> at org.apache.samza.util.TimerUtils$class.updateTimer(TimerUtils.scala:37)
> at org.apache.samza.container.RunLoop.updateTimer(RunLoop.scala:36)
> at org.apache.samza.container.RunLoop.process(RunLoop.scala:98)
> at org.apache.samza.container.RunLoop.run(RunLoop.scala:69)
> at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:555)
> at
> org.apache.samza.container.SamzaContainer$.safeMain(SamzaContainer.scala:93)
> at org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:67)
> at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala)
> Caused by: org.codehaus.jackson.JsonParseException: Unexpected character ('a'
> (code 97)): expected a valid value (number, String, array, object, 'true',
> 'false' or 'null')
> at [Source: [B@7502291e; line: 1, column: 2]
> at org.codehaus.jackson.JsonParser._constructError(JsonParser.java:1291)
> at
> org.codehaus.jackson.impl.JsonParserMinimalBase._reportError(JsonParserMinimalBase.java:385)
> at
> org.codehaus.jackson.impl.JsonParserMinimalBase._reportUnexpectedChar(JsonParserMinimalBase.java:306)
> at
> org.codehaus.jackson.impl.Utf8StreamParser._handleUnexpectedValue(Utf8StreamParser.java:1581)
> at
> org.codehaus.jackson.impl.Utf8StreamParser._nextTokenNotInObject(Utf8StreamParser.java:436)
> at
> org.codehaus.jackson.impl.Utf8StreamParser.nextToken(Utf8StreamParser.java:322)
> at
> org.codehaus.jackson.map.ObjectMapper._initForReading(ObjectMapper.java:2432)
> at
> org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2389)
> at org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1667)
> at org.apache.samza.serializers.JsonSerde.fromBytes(JsonSerde.scala:33)
> at
> org.apache.samza.serializers.SerdeManager.fromBytes(SerdeManager.scala:115)
> at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:300)
> ... 28 more
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
