Details
-
Bug
-
Status: Reopened
-
Minor
-
Resolution: Unresolved
-
1.13.5, 1.16.0, 1.17.1
-
None
Description
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
Attachments
Issue Links
- is related to
-
FLINK-24038 DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager
- Closed
-
FLINK-25235 Re-enable ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange
- Resolved