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