Xingbo Huang created FLINK-29296: ------------------------------------ Summary: OperatorCoordinatorHolder.create throws NPE Key: FLINK-29296 URL: https://issues.apache.org/jira/browse/FLINK-29296 Project: Flink Issue Type: Bug Components: Runtime / Coordination Affects Versions: 1.16.0 Reporter: Xingbo Huang Fix For: 1.16.0
{code:java} 2022-09-13T15:22:42.3864318Z Sep 13 15:22:42 [ERROR] Tests run: 8, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 5.633 s <<< FAILURE! - in org.apache.flink.test.streaming.runtime.SourceNAryInputChainingITCase 2022-09-13T15:22:42.3865377Z Sep 13 15:22:42 [ERROR] org.apache.flink.test.streaming.runtime.SourceNAryInputChainingITCase.testDirectSourcesOnlyExecution Time elapsed: 0.165 s <<< ERROR! 2022-09-13T15:22:42.3867571Z Sep 13 15:22:42 java.lang.RuntimeException: Failed to fetch next result 2022-09-13T15:22:42.3919112Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109) 2022-09-13T15:22:42.3920935Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) 2022-09-13T15:22:42.3922442Z Sep 13 15:22:42 at org.apache.flink.streaming.api.datastream.DataStreamUtils.collectBoundedStream(DataStreamUtils.java:106) 2022-09-13T15:22:42.3924085Z Sep 13 15:22:42 at org.apache.flink.test.streaming.runtime.SourceNAryInputChainingITCase.testDirectSourcesOnlyExecution(SourceNAryInputChainingITCase.java:89) 2022-09-13T15:22:42.3925493Z Sep 13 15:22:42 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 2022-09-13T15:22:42.3926635Z Sep 13 15:22:42 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 2022-09-13T15:22:42.3928378Z Sep 13 15:22:42 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-09-13T15:22:42.3964273Z Sep 13 15:22:42 at java.lang.reflect.Method.invoke(Method.java:498) 2022-09-13T15:22:42.3965054Z Sep 13 15:22:42 at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) 2022-09-13T15:22:42.3965788Z Sep 13 15:22:42 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) 2022-09-13T15:22:42.3966508Z Sep 13 15:22:42 at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) 2022-09-13T15:22:42.3967476Z Sep 13 15:22:42 at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) 2022-09-13T15:22:42.3968432Z Sep 13 15:22:42 at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45) 2022-09-13T15:22:42.3969233Z Sep 13 15:22:42 at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61) 2022-09-13T15:22:42.3969871Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-09-13T15:22:42.3970534Z Sep 13 15:22:42 at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) 2022-09-13T15:22:42.3971453Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) 2022-09-13T15:22:42.3972453Z Sep 13 15:22:42 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) 2022-09-13T15:22:42.3973193Z Sep 13 15:22:42 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) 2022-09-13T15:22:42.3973857Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) 2022-09-13T15:22:42.3974634Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) 2022-09-13T15:22:42.3975420Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) 2022-09-13T15:22:42.3976060Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) 2022-09-13T15:22:42.3976689Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) 2022-09-13T15:22:42.3977555Z Sep 13 15:22:42 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54) 2022-09-13T15:22:42.3978248Z Sep 13 15:22:42 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54) 2022-09-13T15:22:42.3978856Z Sep 13 15:22:42 at org.junit.rules.RunRules.evaluate(RunRules.java:20) 2022-09-13T15:22:42.3979696Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-09-13T15:22:42.3980716Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.run(ParentRunner.java:413) 2022-09-13T15:22:42.3981785Z Sep 13 15:22:42 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) 2022-09-13T15:22:42.3982352Z Sep 13 15:22:42 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) 2022-09-13T15:22:42.3982989Z Sep 13 15:22:42 at org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42) 2022-09-13T15:22:42.3983913Z Sep 13 15:22:42 at org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80) 2022-09-13T15:22:42.3985205Z Sep 13 15:22:42 at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72) 2022-09-13T15:22:42.3986116Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107) 2022-09-13T15:22:42.3987027Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88) 2022-09-13T15:22:42.3988003Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54) 2022-09-13T15:22:42.3988886Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67) 2022-09-13T15:22:42.3989753Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52) 2022-09-13T15:22:42.3990534Z Sep 13 15:22:42 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114) 2022-09-13T15:22:42.3991262Z Sep 13 15:22:42 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86) 2022-09-13T15:22:42.3992048Z Sep 13 15:22:42 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86) 2022-09-13T15:22:42.3992887Z Sep 13 15:22:42 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53) 2022-09-13T15:22:42.3993670Z Sep 13 15:22:42 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188) 2022-09-13T15:22:42.3994498Z Sep 13 15:22:42 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154) 2022-09-13T15:22:42.3995471Z Sep 13 15:22:42 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124) 2022-09-13T15:22:42.3996252Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428) 2022-09-13T15:22:42.3997203Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162) 2022-09-13T15:22:42.3998042Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562) 2022-09-13T15:22:42.3998717Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548) 2022-09-13T15:22:42.3999316Z Sep 13 15:22:42 Caused by: java.io.IOException: Failed to fetch job execution result 2022-09-13T15:22:42.4000057Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184) 2022-09-13T15:22:42.4000925Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121) 2022-09-13T15:22:42.4001806Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) 2022-09-13T15:22:42.4002441Z Sep 13 15:22:42 ... 49 more 2022-09-13T15:22:42.4003019Z Sep 13 15:22:42 Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-09-13T15:22:42.4003764Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) 2022-09-13T15:22:42.4004418Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) 2022-09-13T15:22:42.4005239Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182) 2022-09-13T15:22:42.4005865Z Sep 13 15:22:42 ... 51 more 2022-09-13T15:22:42.4006359Z Sep 13 15:22:42 Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-09-13T15:22:42.4007514Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-09-13T15:22:42.4008348Z Sep 13 15:22:42 at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141) 2022-09-13T15:22:42.4009146Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-09-13T15:22:42.4009823Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628) 2022-09-13T15:22:42.4010525Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996) 2022-09-13T15:22:42.4011295Z Sep 13 15:22:42 at org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:138) 2022-09-13T15:22:42.4012173Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:181) 2022-09-13T15:22:42.4012810Z Sep 13 15:22:42 ... 51 more 2022-09-13T15:22:42.4013448Z Sep 13 15:22:42 Caused by: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster. 2022-09-13T15:22:42.4014278Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) 2022-09-13T15:22:42.4015229Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-09-13T15:22:42.4015959Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-09-13T15:22:42.4016686Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-09-13T15:22:42.4017624Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1609) 2022-09-13T15:22:42.4018352Z Sep 13 15:22:42 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 2022-09-13T15:22:42.4019064Z Sep 13 15:22:42 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 2022-09-13T15:22:42.4019644Z Sep 13 15:22:42 at java.lang.Thread.run(Thread.java:748) 2022-09-13T15:22:42.4021477Z Sep 13 15:22:42 Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator MultipleInputOperator [Source: source-1, Source: source-2, Source: source-3] 2022-09-13T15:22:42.4022481Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) 2022-09-13T15:22:42.4023211Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) 2022-09-13T15:22:42.4023950Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) 2022-09-13T15:22:42.4024490Z Sep 13 15:22:42 ... 3 more 2022-09-13T15:22:42.4025502Z Sep 13 15:22:42 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator MultipleInputOperator [Source: source-1, Source: source-2, Source: source-3] 2022-09-13T15:22:42.4026394Z Sep 13 15:22:42 at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) 2022-09-13T15:22:42.4027181Z Sep 13 15:22:42 at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) 2022-09-13T15:22:42.4028117Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) 2022-09-13T15:22:42.4028635Z Sep 13 15:22:42 ... 3 more 2022-09-13T15:22:42.4029580Z Sep 13 15:22:42 Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator MultipleInputOperator [Source: source-1, Source: source-2, Source: source-3] 2022-09-13T15:22:42.4030458Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:229) 2022-09-13T15:22:42.4031405Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:901) 2022-09-13T15:22:42.4032277Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:891) 2022-09-13T15:22:42.4033150Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:848) 2022-09-13T15:22:42.4034250Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:830) 2022-09-13T15:22:42.4035132Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:198) 2022-09-13T15:22:42.4036060Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:156) 2022-09-13T15:22:42.4037173Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:361) 2022-09-13T15:22:42.4038096Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:206) 2022-09-13T15:22:42.4038824Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:134) 2022-09-13T15:22:42.4039610Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:152) 2022-09-13T15:22:42.4040587Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:119) 2022-09-13T15:22:42.4041442Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:369) 2022-09-13T15:22:42.4042111Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:346) 2022-09-13T15:22:42.4042959Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:123) 2022-09-13T15:22:42.4043989Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:95) 2022-09-13T15:22:42.4045007Z Sep 13 15:22:42 at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) 2022-09-13T15:22:42.4045573Z Sep 13 15:22:42 ... 4 more 2022-09-13T15:22:42.4045981Z Sep 13 15:22:42 Caused by: java.lang.NullPointerException 2022-09-13T15:22:42.4046657Z Sep 13 15:22:42 at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:488) 2022-09-13T15:22:42.4047747Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:286) 2022-09-13T15:22:42.4048604Z Sep 13 15:22:42 at org.apache.f {code} https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40968&view=logs&j=a57e0635-3fad-5b08-57c7-a4142d7d6fa9&t=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7 -- This message was sent by Atlassian Jira (v8.20.10#820010)