2022-01-01T03:44:30.5377646Z Jan 01 03:44:30 [ERROR] org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange Time elapsed: 38.081 s <<< ERROR!
2022-01-01T03:44:30.5378624Z Jan 01 03:44:30 java.lang.IllegalStateException: MiniCluster is not yet running or has already been shut down.
2022-01-01T03:44:30.5379491Z Jan 01 03:44:30 at org.apache.flink.util.Preconditions.checkState(Preconditions.java:193)
2022-01-01T03:44:30.5380458Z Jan 01 03:44:30 at org.apache.flink.runtime.minicluster.MiniCluster.getDispatcherGatewayFuture(MiniCluster.java:923)
2022-01-01T03:44:30.5381367Z Jan 01 03:44:30 at org.apache.flink.runtime.minicluster.TestingMiniCluster.getDispatcherGatewayFuture(TestingMiniCluster.java:118)
2022-01-01T03:44:30.5382348Z Jan 01 03:44:30 at org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.lambda$getNextLeadingDispatcherGateway$2(ZooKeeperLeaderElectionITCase.java:164)
2022-01-01T03:44:30.5383406Z Jan 01 03:44:30 at org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:160)
2022-01-01T03:44:30.5384325Z Jan 01 03:44:30 at org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:144)
2022-01-01T03:44:30.5385659Z Jan 01 03:44:30 at org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.getNextLeadingDispatcherGateway(ZooKeeperLeaderElectionITCase.java:161)
2022-01-01T03:44:30.5387074Z Jan 01 03:44:30 at org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange(ZooKeeperLeaderElectionITCase.java:122)
2022-01-01T03:44:30.5388228Z Jan 01 03:44:30 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-01-01T03:44:30.5388833Z Jan 01 03:44:30 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-01-01T03:44:30.5389633Z Jan 01 03:44:30 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-01-01T03:44:30.5390265Z Jan 01 03:44:30 at java.lang.reflect.Method.invoke(Method.java:498)
2022-01-01T03:44:30.5390833Z Jan 01 03:44:30 at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-01-01T03:44:30.5391733Z Jan 01 03:44:30 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-01-01T03:44:30.5392700Z Jan 01 03:44:30 at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-01-01T03:44:30.5393689Z Jan 01 03:44:30 at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-01-01T03:44:30.5394266Z Jan 01 03:44:30 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
2022-01-01T03:44:30.5394955Z Jan 01 03:44:30 at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2022-01-01T03:44:30.5395523Z Jan 01 03:44:30 at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2022-01-01T03:44:30.5396061Z Jan 01 03:44:30 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-01-01T03:44:30.5396774Z Jan 01 03:44:30 at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2022-01-01T03:44:30.5397354Z Jan 01 03:44:30 at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2022-01-01T03:44:30.5397932Z Jan 01 03:44:30 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2022-01-01T03:44:30.5398523Z Jan 01 03:44:30 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2022-01-01T03:44:30.5399094Z Jan 01 03:44:30 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-01-01T03:44:30.5399632Z Jan 01 03:44:30 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-01-01T03:44:30.5400187Z Jan 01 03:44:30 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-01-01T03:44:30.5400729Z Jan 01 03:44:30 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-01-01T03:44:30.5401272Z Jan 01 03:44:30 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-01-01T03:44:30.5401835Z Jan 01 03:44:30 at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2022-01-01T03:44:30.5402493Z Jan 01 03:44:30 at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2022-01-01T03:44:30.5403250Z Jan 01 03:44:30 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-01-01T03:44:30.5403784Z Jan 01 03:44:30 at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-01-01T03:44:30.5404280Z Jan 01 03:44:30 at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
2022-01-01T03:44:30.5404870Z Jan 01 03:44:30 at org.junit.runner.JUnitCore.run(JUnitCore.java:115)
2022-01-01T03:44:30.5405416Z Jan 01 03:44:30 at org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
2022-01-01T03:44:30.5406047Z Jan 01 03:44:30 at org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
2022-01-01T03:44:30.5406661Z Jan 01 03:44:30 at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
2022-01-01T03:44:30.5407311Z Jan 01 03:44:30 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2022-01-01T03:44:30.5408011Z Jan 01 03:44:30 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2022-01-01T03:44:30.5408712Z Jan 01 03:44:30 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2022-01-01T03:44:30.5409608Z Jan 01 03:44:30 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2022-01-01T03:44:30.5410332Z Jan 01 03:44:30 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2022-01-01T03:44:30.5410987Z Jan 01 03:44:30 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2022-01-01T03:44:30.5411594Z Jan 01 03:44:30 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2022-01-01T03:44:30.5412268Z Jan 01 03:44:30 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2022-01-01T03:44:30.5413242Z Jan 01 03:44:30 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2022-01-01T03:44:30.5413943Z Jan 01 03:44:30 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2022-01-01T03:44:30.5414703Z Jan 01 03:44:30 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2022-01-01T03:44:30.5415386Z Jan 01 03:44:30 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
2022-01-01T03:44:30.5416040Z Jan 01 03:44:30 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2022-01-01T03:44:30.5416660Z Jan 01 03:44:30 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2022-01-01T03:44:30.5417234Z Jan 01 03:44:30 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2022-01-01T03:44:30.5417811Z Jan 01 03:44:30 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-01-01T03:44:30.5418386Z Jan 01 03:44:30 Suppressed: org.apache.flink.util.FlinkException: Could not close resource.
2022-01-01T03:44:30.5418972Z Jan 01 03:44:30 at org.apache.flink.util.AutoCloseableAsync.close(AutoCloseableAsync.java:39)
2022-01-01T03:44:30.5419709Z Jan 01 03:44:30 at org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange(ZooKeeperLeaderElectionITCase.java:153)
2022-01-01T03:44:30.5420321Z Jan 01 03:44:30 ... 46 more
2022-01-01T03:44:30.5420824Z Jan 01 03:44:30 Caused by: org.apache.flink.util.FlinkException: Cannot deregister application. Resource manager service is not available.
2022-01-01T03:44:30.5421584Z Jan 01 03:44:30 at org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl.deregisterApplication(ResourceManagerServiceImpl.java:146)
2022-01-01T03:44:30.5422429Z Jan 01 03:44:30 at org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent.lambda$stopApplication$1(DispatcherResourceManagerComponent.java:131)
2022-01-01T03:44:30.5423352Z Jan 01 03:44:30 at org.apache.flink.util.concurrent.FutureUtils.lambda$composeAfterwards$20(FutureUtils.java:728)
2022-01-01T03:44:30.5424004Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-01T03:44:30.5424687Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-01T03:44:30.5425318Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-01T03:44:30.5425922Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-01-01T03:44:30.5426527Z Jan 01 03:44:30 at org.apache.flink.util.concurrent.FutureUtils.lambda$null$19(FutureUtils.java:739)
2022-01-01T03:44:30.5427139Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-01T03:44:30.5427742Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-01T03:44:30.5428477Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-01T03:44:30.5429074Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-01-01T03:44:30.5429714Z Jan 01 03:44:30 at org.apache.flink.runtime.rest.RestServerEndpoint.lambda$closeAsync$1(RestServerEndpoint.java:366)
2022-01-01T03:44:30.5430367Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-01T03:44:30.5431002Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-01T03:44:30.5431644Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-01T03:44:30.5432353Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-01-01T03:44:30.5433073Z Jan 01 03:44:30 at org.apache.flink.util.concurrent.FutureUtils.lambda$null$19(FutureUtils.java:739)
2022-01-01T03:44:30.5433711Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-01T03:44:30.5434339Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-01T03:44:30.5435007Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-01T03:44:30.5435607Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-01-01T03:44:30.5436258Z Jan 01 03:44:30 at org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint.lambda$null$0(DispatcherRestEndpoint.java:155)
2022-01-01T03:44:30.5436909Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-01T03:44:30.5437500Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792)
2022-01-01T03:44:30.5438069Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153)
2022-01-01T03:44:30.5438740Z Jan 01 03:44:30 at org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint.lambda$shutDownInternal$1(DispatcherRestEndpoint.java:146)
2022-01-01T03:44:30.5439420Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-01T03:44:30.5440031Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-01T03:44:30.5440648Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-01T03:44:30.5441236Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-01-01T03:44:30.5441862Z Jan 01 03:44:30 at org.apache.flink.util.concurrent.FutureUtils.lambda$runAfterwardsAsync$18(FutureUtils.java:704)
2022-01-01T03:44:30.5442498Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-01T03:44:30.5443310Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-01T03:44:30.5443945Z Jan 01 03:44:30 at java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:457)
2022-01-01T03:44:30.5444577Z Jan 01 03:44:30 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-01-01T03:44:30.5445146Z Jan 01 03:44:30 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-01-01T03:44:30.5445717Z Jan 01 03:44:30 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-01-01T03:44:30.5446291Z Jan 01 03:44:30 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-01-01T03:44:30.5446944Z Jan 01 03:44:30 Suppressed: org.apache.flink.util.FlinkException: Cannot deregister application. Resource manager service is not available.
2022-01-01T03:44:30.5447557Z Jan 01 03:44:30 ... 39 more
2022-01-01T03:44:30.5448057Z Jan 01 03:44:30 Suppressed: org.apache.flink.util.FlinkException: Cannot deregister application. Resource manager service is not available.
2022-01-01T03:44:30.5448566Z Jan 01 03:44:30 ... 39 more
2022-01-01T03:44:30.5448869Z Jan 01 03:44:30
Bug
Minor
FLINK-25235 Re-enable ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange