Hi, `JobManagerCommunicationUtils` was never part of Flink's API. It was an internal class, for our internal unit tests. Note that Flink's public API is annotated with `@Public`, `@PublicEvolving` or `@Experimental`. Anything else by default is internal (sometimes to avoid confusion we are annotating internal classes with `@Internal`).
JobManagerCommunicationUtils seems to be replaced with `MiniClusterResource` [1] as part of [2]. Note that MiniClusterResource is also not a public API, so it's subject to change or to be completely removed without warning. You can read about how to test your applications here [3], and about `MiniClusterResource` in particular here [4]. Piotrek PS Flink 1.5 is also not supported for something like 2 years now? Currently officially supported Flink versions are 1.13, and 1.14 so I would encourage you to upgrade to one of those. [1] https://github.com/apache/flink/commits/release-1.5/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/JobManagerCommunicationUtils.java [2] https://issues.apache.org/jira/browse/FLINK-8703 [3] https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/testing/ [4] https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/testing/#testing-flink-jobs pt., 8 paź 2021 o 10:11 Felipe Gutierrez <[email protected]> napisał(a): > 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* >
