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年前467ビュー
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
回答済み 2年前

ログインしていません。 ログイン 回答を投稿する。

優れた回答とは、質問に明確に答え、建設的なフィードバックを提供し、質問者の専門分野におけるスキルの向上を促すものです。

質問に答えるためのガイドライン

関連するコンテンツ