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?
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.