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 >
