Hi, I'm running a simple samza topology that reads from a kafka topic that
only has two Strings
xx:xx:xx:xxxx;xx
And its throwing an error
Caught exception in process loop.
org.codehaus.jackson.JsonParseException: Unexpected character ('F' (code
70)): expected a valid value (number, String, array, object, 'true',
'false' or 'null')
at [Source: [B@56dfb465; 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$$anonfun$org$apache$samza$system$SystemConsumers$$poll$5.apply(SystemConsumers.scala:245)
at
org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$SystemConsumers$$poll$5.apply(SystemConsumers.scala:242)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at org.apache.samza.system.SystemConsumers.org
$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:242)
at
org.apache.samza.system.SystemConsumers$$anon$1$$anonfun$call$2.apply(SystemConsumers.scala:180)
at
org.apache.samza.system.SystemConsumers$$anon$1$$anonfun$call$2.apply(SystemConsumers.scala:180)
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$$anon$1.call(SystemConsumers.scala:180)
at
org.apache.samza.util.DoublingBackOff.maybeCall(DoublingBackOff.scala:44)
at org.apache.samza.system.SystemConsumers.choose(SystemConsumers.scala:208)
at org.apache.samza.container.RunLoop.process(RunLoop.scala:73)
at org.apache.samza.container.RunLoop.run(RunLoop.scala:57)
at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:504)
at org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:81)
at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala)
Has anyone experienced this error before?
--
------------------------------------------
Telles Mota Vidal Nobrega
M.sc. Candidate at UFCG
B.sc. in Computer Science at UFCG
Software Engineer at OpenStack Project - HP/LSD-UFCG
