Hi, I have updated the PR for IGNITE-3303. I have observed that we will not be able to stop streaming job without static field as explained below
https://stackoverflow.com/questions/44441153/how-to-stop-a-flink-streaming-job-from-program I have updated the test similar to flink Nifi source tests https://github.com/apache/flink/blob/4f50dc4df14d00203a03873edaf4252082ef4d38/flink-connectors/flink-connector-nifi/src/test/java/org/apache/flink/streaming/connectors/nifi/examples/NiFiSourceTopologyExample.java Please review and share feedback. https://github.com/apache/ignite/pull/870 Regards, Saikat
