[jira] [Resolved] (SAMZA-2190) Cannot deserialize an incoming message

["AndyChau (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

AndyChau resolved SAMZA-2190.
-----------------------------
    Resolution: Fixed

already settled.

Becaus test kafka. random input code'a' with producer.

samza init will check kafka offset and detail.

can not deserialize .

can clear the kafka logs and restart kafka be ok.

> 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)