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
