flink-htm
flink-htm copied to clipboard
Implement StoppableFunction
The RiverSource should support a graceful stop by implementing StoppableFunction. Streaming jobs are stoppable by the user as per FLINK-2111.