It's a bug in the visualization (I guess), also the example provided here: https://github.com/apache/zeppelin/pull/2809
is not working anymore I opened this issue: https://issues.apache.org/jira/browse/ZEPPELIN-4367 If someone can mentor me on how to fix this, I can do it. Thanks a lot Andrea Il giorno mar 8 ott 2019 alle ore 12:06 Andrea Santurbano <sant...@gmail.com> ha scritto: > Following the Interpreter log (seems to be good): > > https://gist.github.com/conker84/aad9b9a220e781b30d5aab1ddc74a4d7#file-zeppelin-interpreter-debug-log > > Il giorno mar 8 ott 2019 alle ore 11:38 Andrea Santurbano < > sant...@gmail.com> ha scritto: > >> Seems to be different, please check here: >> >> https://gist.github.com/conker84/4a54df4c73dab310cdc9284f15e90075 >> >> Can you mentor me about what I'm wrong? >> >> >> >> Il giorno mar 8 ott 2019 alle ore 11:13 Jeff Zhang <zjf...@gmail.com> ha >> scritto: >> >>> The the following line is suspicious to me. >>> >>> https://github.com/conker84/zeppelin/blob/kafka/kafka/src/main/java/org/apache/zeppelin/kafka/KafkaKSQLInterpreter.java#L120 >>> >>> Could you add the following line to log4j.properties so that you can see >>> more logging info. >>> log4j.logger.org.apache.zeppelin.interpreter=DEBUG >>> >>> Then you should be able to see logging like following in the interpreter >>> log. That means interpreter generate output and sent it to zeppelin >>> server. >>> If you don't see this kind of logging, then it should be your interpreter >>> issue. >>> >>> DEBUG [2019-10-08 17:11:14,822] ({pool-1-thread-3} >>> RemoteInterpreterServer.java[resourcePoolGetAll]:996) - Request >>> resourcePoolGetAll from ZeppelinServer >>> DEBUG [2019-10-08 17:11:15,813] ({grpc-default-executor-0} >>> RemoteInterpreterServer.java[onAppend]:830) - Output Append: >>> >>> DEBUG [2019-10-08 17:11:15,815] ({grpc-default-executor-0} >>> RemoteInterpreterServer.java[onUpdate]:840) - Output Update for index 7: >>> DEBUG [2019-10-08 17:11:15,816] ({grpc-default-executor-0} >>> RemoteInterpreterServer.java[onAppend]:830) - Output Append: 8 >>> >>> DEBUG [2019-10-08 17:11:15,826] ({pool-1-thread-3} >>> RemoteInterpreterServer.java[resourcePoolGetAll]:996) - Request >>> resourcePoolGetAll from ZeppelinServer >>> DEBUG [2019-10-08 17:11:16,808] ({grpc-default-executor-0} >>> RemoteInterpreterServer.java[onAppend]:830) - Output Append: >>> >>> DEBUG [2019-10-08 17:11:16,808] ({grpc-default-executor-0} >>> RemoteInterpreterServer.java[onUpdate]:840) - Output Update for index 8: >>> DEBUG [2019-10-08 17:11:16,809] ({grpc-default-executor-0} >>> RemoteInterpreterServer.java[onAppend]:830) - Output Append: 9 >>> >>> >>> Andrea Santurbano <sant...@gmail.com> 于2019年10月8日周二 下午4:36写道： >>> >>> > Did you check the animated gif that I provided in the first email? >>> Looks >>> > like a problem in the visualization. >>> > >>> > Btw I expect the same behaviour as here: >>> > >>> > https://github.com/apache/zeppelin/pull/2809 >>> > and >>> > https://github.com/apache/zeppelin/pull/2873 >>> > >>> > >>> > >>> > Il giorno mar 8 ott 2019 alle ore 10:04 Jeff Zhang <zjf...@gmail.com> >>> ha >>> > scritto: >>> > >>> > > I encounter some issues when integrating flink streaming, not sure >>> the >>> > same >>> > > as you. >>> > > Just curious to know what is your expected output if it is streaming >>> job >>> > > and output is generated continuously. >>> > > >>> > > >>> > > Andrea Santurbano <sant...@gmail.com> 于2019年10月8日周二 下午4:01写道： >>> > > >>> > > > No clue at all? >>> > > > >>> > > > Il giorno lun 7 ott 2019 alle ore 14:14 Andrea Santurbano < >>> > > > sant...@gmail.com> >>> > > > ha scritto: >>> > > > >>> > > > > Could it be a bug in the front-end? Or Am I missing something? >>> > > > > >>> > > > > Il giorno lun 7 ott 2019 alle ore 09:39 Andrea Santurbano < >>> > > > > sant...@gmail.com> ha scritto: >>> > > > > >>> > > > >> More or less yes (it transforms sql statements into KafkaStreams >>> > > jobs). >>> > > > >> But I simply call a rest endpoint that has as response >>> > > > Transfer-Encoding: >>> > > > >> chunked and the data comes in as you can check with the linked >>> > image. >>> > > > >> The only thing it's that I have blank rows (but if I debug the >>> code >>> > > the >>> > > > >> data is in there) and when I stop the job every blank row gets >>> the >>> > > > correct >>> > > > >> value. >>> > > > >> >>> > > > >> >>> > > > >> Il giorno lun 7 ott 2019 alle ore 08:06 Jeff Zhang < >>> > zjf...@gmail.com> >>> > > > ha >>> > > > >> scritto: >>> > > > >> >>> > > > >>> I don't know much about KSQL, is each running a streaming job >>> which >>> > > > never >>> > > > >>> stops ? >>> > > > >>> >>> > > > >>> Andrea Santurbano <sant...@gmail.com> 于2019年10月7日周一 上午4:09写道： >>> > > > >>> >>> > > > >>> > Hi guys, >>> > > > >>> > I'm building a KQL interpreter. KSQL is the streaming SQL >>> engine >>> > > that >>> > > > >>> > enables real-time data processing against Apache Kafka >>> topics. >>> > > > >>> > I created an interpreter that leverages the >>> > InterpreterOutputStream >>> > > > >>> class >>> > > > >>> > in order to stream the result from the backend to the >>> frontend, >>> > > but I >>> > > > >>> get >>> > > > >>> > the following representation in the frontend: >>> > > > >>> > >>> > > > >>> > https://imgur.com/a/J7unk25 >>> > > > >>> > >>> > > > >>> > What am I doing wrong? >>> > > > >>> > >>> > > > >>> > Following the Interpreter implementation: >>> > > > >>> > >>> > > > >>> > >>> > > > >>> > >>> > > > >>> >>> > > > >>> > > >>> > >>> https://github.com/conker84/zeppelin/blob/kafka/kafka/src/main/java/org/apache/zeppelin/kafka/KafkaKSQLInterpreter.java >>> > > > >>> > >>> > > > >>> > Thanks a lot >>> > > > >>> > >>> > > > >>> > Andrea >>> > > > >>> > >>> > > > >>> >>> > > > >>> >>> > > > >>> -- >>> > > > >>> Best Regards >>> > > > >>> >>> > > > >>> Jeff Zhang >>> > > > >>> >>> > > > >> >>> > > > >>> > > >>> > > >>> > > -- >>> > > Best Regards >>> > > >>> > > Jeff Zhang >>> > > >>> > >>> >>> >>> -- >>> Best Regards >>> >>> Jeff Zhang >>> >>
