AnsweredAssumed Answered

Mapr-stream sample program issue

Question asked by catverdier on Aug 24, 2016
Latest reply on Aug 29, 2016 by catverdier


I have followed this tutorial : https://www.javacodegeeks.com/2016/03/getting-started-mapr-streams.html

 

I have started the Producer which works properly

 

When I start the consumer I got the following error :

 

$ java -cp $(mapr classpath):./mapr-streams-examples-1.0-SNAPSHOT-jar-with-dependencies.jar com.mapr.examples.Run consumer

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J: Found binding in [jar:file:/opt/mapr/lib/slf4j-log4j12-1.7.12.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/mapr/mapr-streams-examples-1.0-SNAPSHOT-jar-with-dependencies.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]

Got 3124 records after 0 timeouts

Exception in thread "main" com.fasterxml.jackson.core.JsonParseException: Unexpected character ('7' (code 55)): was expecting double-quote to start field name

at [Source: {"type":"test", "t":4055065,766, "k":0}; line: 1, column: 30]

        at com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1586)

        at com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:521)

        at com.fasterxml.jackson.core.base.ParserMinimalBase._reportUnexpectedChar(ParserMinimalBase.java:450)

        at com.fasterxml.jackson.core.json.ReaderBasedJsonParser._handleOddName(ReaderBasedJsonParser.java:1701)

        at com.fasterxml.jackson.core.json.ReaderBasedJsonParser.nextFieldName(ReaderBasedJsonParser.java:872)

        at com.fasterxml.jackson.databind.deser.std.BaseNodeDeserializer.deserializeObject(JsonNodeDeserializer.java:219)

        at com.fasterxml.jackson.databind.deser.std.JsonNodeDeserializer.deserialize(JsonNodeDeserializer.java:69)

        at com.fasterxml.jackson.databind.deser.std.JsonNodeDeserializer.deserialize(JsonNodeDeserializer.java:15)

        at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3788)

        at com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:2324)

        at com.mapr.examples.Consumer.main(Consumer.java:61)

        at com.mapr.examples.Run.main(Run.java:19)

 

Is there any fix to apply ?

Thanks

Outcomes