org.apache.flink.runtime.jobmaster.JobManagerRunner to java.util.concurrent.CompletableFuture<org.apache.flink.runtime.jobmaster.JobManagerRunner>