Hello there, what is the replacement from Flink 1.4 to Flink 1.5 of the class JobManagerCommunicationUtils.java [1] below?
JobManagerCommunicationUtils.cancelCurrentJob JobManagerCommunicationUtils.waitUntilNoJobIsRunning I want to upgrade Flink from 1.4 to 1.5 but I cant find this class in the docs of the previous version [2] neither on the next version [3]. My plan is also to upgrade Flink to the lates version. But if I cannot find a way to the next version 1.4 -> 1.5, I suppose that for a greater it will be even more difficult. [1] https://github.com/a0x8o/flink/blob/master/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/JobManagerCommunicationUtils.java#L38-L60 [2] https://ci.apache.org/projects/flink/flink-docs-release-1.4/api/java/org/apache/flink/streaming/connectors/kafka/package-summary.html [3] https://ci.apache.org/projects/flink/flink-docs-release-1.5/api/java/org/apache/flink/streaming/connectors/kafka/package-summary.html Thanks in advance, Felipe *--* *-- Felipe Gutierrez*
