Search code examples
apache-flink

Flink example job of long-running streaming processing

I'm looking for a Flink example job of long-running streaming processing for test purposes. I checked the streaming/WordCount included in the Flink project, but seems it is not long-running, after processing the input file, it exits.

Do I need to write one by myself? What is the simplest way to get an endless stream input?

Solution

  • The WordCount example exits because its source is finite. Once it has fully processed its input, it exits.

    The Flink Operations Playground is a nice example of a streaming job that runs forever.