Zeppelin is not printing a Flink DataStream

Question

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()
```

Answer

If you are using %flink.pyflink or %flink as your interpreters, you will need to use the [ZeppelinContext](https://zeppelin.apache.org/docs/0.9.0/interpreter/flink.html#zeppelincontext) to visualize the results within the notebook.

```scala
%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.](https://aws.amazon.com/blogs/big-data/query-your-data-streams-interactively-using-kinesis-data-analytics-studio-and-python/)

Zeppelin is not printing a Flink DataStream

相關內容