Thanks.
On Thu, Aug 7, 2014 at 1:54 PM, Chris Riccomini < [email protected]> wrote: > Hey Telles, > > This is definitely a serde error. It sounds like your message is not > properly formatted as a JSON blob. > > If you are trying to just use a string as the message (vs. a well > formatted JSON blob), then you should use the StringSerde. > > Cheers, > Chris > > On 8/7/14 8:05 AM, "Telles Nobrega" <[email protected]> wrote: > > >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(JsonParserMin > >imalBase.java:385) > >at > >org.codehaus.jackson.impl.JsonParserMinimalBase._reportUnexpectedChar(Json > >ParserMinimalBase.java:306) > > at > >org.codehaus.jackson.impl.Utf8StreamParser._handleUnexpectedValue(Utf8Stre > >amParser.java:1581) > >at > >org.codehaus.jackson.impl.Utf8StreamParser._nextTokenNotInObject(Utf8Strea > >mParser.java:436) > > at > >org.codehaus.jackson.impl.Utf8StreamParser.nextToken(Utf8StreamParser.java > >:322) > >at > >org.codehaus.jackson.map.ObjectMapper._initForReading(ObjectMapper.java:24 > >32) > > at > >org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2 > >389) > >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$S > >ystemConsumers$$poll$5.apply(SystemConsumers.scala:245) > > at > >org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$S > >ystemConsumers$$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(Syst > >emConsumers.scala:180) > >at > >org.apache.samza.system.SystemConsumers$$anon$1$$anonfun$call$2.apply(Syst > >emConsumers.scala:180) > > at > >scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scal > >a:244) > >at > >scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scal > >a: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 > > -- ------------------------------------------ Telles Mota Vidal Nobrega M.sc. Candidate at UFCG B.sc. in Computer Science at UFCG Software Engineer at OpenStack Project - HP/LSD-UFCG
