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 >> >
