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)
