Can you give and example on how to use string serde, i'm getting an error when trying to set to string
:53:26:804Got system producers: Set(kafka) 17:53:26:809Got serdes: Set(string) 17:53:29:206Container container_1407433587782_0001_01_000017 failed with exit code 1 - Exception from container-launch: On Thu, Aug 7, 2014 at 2:41 PM, Telles Nobrega <[email protected]> wrote: > 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 > -- ------------------------------------------ Telles Mota Vidal Nobrega M.sc. Candidate at UFCG B.sc. in Computer Science at UFCG Software Engineer at OpenStack Project - HP/LSD-UFCG
