Alex Ott created ZEPPELIN-4841: ---------------------------------- Summary: KSQL interpreter doesn't work with Confluent 5.5.0 Key: ZEPPELIN-4841 URL: https://issues.apache.org/jira/browse/ZEPPELIN-4841 Project: Zeppelin Issue Type: Improvement Components: Interpreters Affects Versions: 0.9.0 Reporter: Alex Ott
KSQL Interpreter is broken in the 0.9.0-preview1. When executing with KSQL on Confluent 5.5.0 {noformat} %ksql select * from tweets_txt EMIT CHANGES; {noformat} I'm getting following error: {noformat} java.lang.RuntimeException: com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize instance of `java.util.LinkedHashMap` out of START_ARRAY token at [Source: (String)"[{"header":{"queryId":"none","schema":"`ROWTIME` BIGINT, `ROWKEY` STRING, `LANG` STRING, `ID` BIGINT, `TEXT` STRING, `EVENT_TS` STRING"}},"; line: 1, column: 1] at org.apache.zeppelin.ksql.KSQLRestService$1.onMessage(KSQLRestService.java:140) at org.apache.zeppelin.ksql.BasicKSQLHttpClient.connectAsync(BasicKSQLHttpClient.java:101) at org.apache.zeppelin.ksql.KSQLRestService.executeSelect(KSQLRestService.java:128) at org.apache.zeppelin.ksql.KSQLRestService.executeQuery(KSQLRestService.java:70) at org.apache.zeppelin.ksql.KSQLInterpreter.executeQuery(KSQLInterpreter.java:119) at org.apache.zeppelin.ksql.KSQLInterpreter.interpret(KSQLInterpreter.java:108) at org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:110) at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:684) at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:577) at org.apache.zeppelin.scheduler.Job.run(Job.java:172) at org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:130) at org.apache.zeppelin.scheduler.FIFOScheduler.lambda$runJobInScheduler$0(FIFOScheduler.java:39) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize instance of `java.util.LinkedHashMap` out of START_ARRAY token at [Source: (String)"[{"header":{"queryId":"none","schema":"`ROWTIME` BIGINT, `ROWKEY` STRING, `LANG` STRING, `ID` BIGINT, `TEXT` STRING, `EVENT_TS` STRING"}},"; line: 1, column: 1] at com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:63) at com.fasterxml.jackson.databind.DeserializationContext.reportInputMismatch(DeserializationContext.java:1343) at com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java:1139) at com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java:1093) at com.fasterxml.jackson.databind.deser.std.StdDeserializer._deserializeFromEmpty(StdDeserializer.java:600) at com.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:360) at com.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:29) at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4013) at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3004) at org.apache.zeppelin.ksql.KSQLRestService$1.onMessage(KSQLRestService.java:132) ... 14 more {noformat} -- This message was sent by Atlassian Jira (v8.3.4#803005)