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
asked a year ago403 views
1 Answer
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
answered a year ago

You are not logged in. Log in to post an answer.

A good answer clearly answers the question and provides constructive feedback and encourages professional growth in the question asker.

Guidelines for Answering Questions