Zeppelin is not printing a Flink DataStream

0

I'm running this code in a Zeppelin notebook (via Kinesis Analytics Studio), and it is not printing anything:

env.fromElements("a", "b", "c").print()
env.execute()
mattyf
질문됨 2년 전434회 조회
1개 답변
0

If you are using %flink.pyflink or %flink as your interpreters, you will need to use the ZeppelinContext to visualize the results within the notebook.

%flink
// create a DataStream
val dataStream = senv.fromElements("Alice", "Bob", "John")

// interpret the insert-only DataStream as a Table
val inputTable = stenv.fromDataStream(dataStream)

z.show(inputTable, streamType="update")

For more PyFlink specific examples, see Query your data streams interactively using Kinesis Data Analytics Studio and Python.

profile pictureAWS
Jeremy
답변함 일 년 전

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠