[jira] [Commented] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

[Robert Metzger (Jira)]

    [ 
https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649270#comment-17649270
 ] 

Robert Metzger commented on FLINK-29755:
----------------------------------------

Another instability with the Pulsar E2e tests:

{code}
2022-12-18T16:01:17.3859942Z Dec 18 16:01:17 [ERROR] 
org.apache.flink.tests.util.pulsar.PulsarSourceUnorderedE2ECase.testScaleDown(TestEnvironment,
 DataStreamSourceExternalContext, CheckpointingMode)[2]  Time elapsed: 124.035 
s  <<< FAILURE!

022-12-18T16:01:17.3861087Z Dec 18 16:01:17 Expecting
2022-12-18T16:01:17.3861386Z Dec 18 16:01:17   <CompletableFuture[Incomplete]>
2022-12-18T16:01:17.3861716Z Dec 18 16:01:17 to be completed within 2M.
2022-12-18T16:01:17.3861992Z Dec 18 16:01:17 
2022-12-18T16:01:17.3862369Z Dec 18 16:01:17 exception caught while trying to 
get the future result: java.util.concurrent.TimeoutException
2022-12-18T16:01:17.3862901Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784)
2022-12-18T16:01:17.3863456Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2022-12-18T16:01:17.3863987Z Dec 18 16:01:17    at 
org.assertj.core.internal.Futures.assertSucceededWithin(Futures.java:109)
2022-12-18T16:01:17.3864610Z Dec 18 16:01:17    at 
org.assertj.core.api.AbstractCompletableFutureAssert.internalSucceedsWithin(AbstractCompletableFutureAssert.java:400)
2022-12-18T16:01:17.3865289Z Dec 18 16:01:17    at 
org.assertj.core.api.AbstractCompletableFutureAssert.succeedsWithin(AbstractCompletableFutureAssert.java:396)
2022-12-18T16:01:17.3866019Z Dec 18 16:01:17    at 
org.apache.flink.connector.pulsar.testutils.source.UnorderedSourceTestSuiteBase.checkResultWithSemantic(UnorderedSourceTestSuiteBase.java:55)
2022-12-18T16:01:17.3866771Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:329)
2022-12-18T16:01:17.3867465Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testScaleDown(SourceTestSuiteBase.java:279)
2022-12-18T16:01:17.3868017Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-12-18T16:01:17.3868513Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-12-18T16:01:17.3869078Z Dec 18 16:01:17    at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-12-18T16:01:17.3869596Z Dec 18 16:01:17    at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-12-18T16:01:17.3870098Z Dec 18 16:01:17    at 
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
2022-12-18T16:01:17.3870794Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-12-18T16:01:17.3871458Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-12-18T16:01:17.3872128Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
2022-12-18T16:01:17.3872754Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
2022-12-18T16:01:17.3873407Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
2022-12-18T16:01:17.3874141Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
2022-12-18T16:01:17.3874918Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
2022-12-18T16:01:17.3875638Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-12-18T16:01:17.3876515Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-12-18T16:01:17.3877239Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-12-18T16:01:17.3877912Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-12-18T16:01:17.3878578Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
2022-12-18T16:01:17.3879243Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
2022-12-18T16:01:17.3879939Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
2022-12-18T16:01:17.3889139Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.3889972Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
2022-12-18T16:01:17.3890666Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
2022-12-18T16:01:17.3891311Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
2022-12-18T16:01:17.3893070Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.3893722Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.3894372Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.3895063Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.3895674Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.3896322Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.3896956Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.3897568Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.3898303Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.3899178Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.submit(ForkJoinPoolHierarchicalTestExecutorService.java:118)
2022-12-18T16:01:17.3899956Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2022-12-18T16:01:17.3900656Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2022-12-18T16:01:17.3901327Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
2022-12-18T16:01:17.3902009Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.3902618Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.3903153Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.3903811Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2022-12-18T16:01:17.3904448Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.3904969Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.3905502Z Dec 18 16:01:17    at 
java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
2022-12-18T16:01:17.3906039Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
2022-12-18T16:01:17.3906570Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.3907112Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.3907650Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.3908172Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.3908725Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.3909289Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.3909831Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.3910350Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.3910878Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.3911419Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.3911941Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.3912469Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.3913023Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.3913576Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.3914115Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.3914633Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.3915218Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.3915877Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
2022-12-18T16:01:17.3916539Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.3917185Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.3917844Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.3918448Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.3919031Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.3931092Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.3931775Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4294232Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4295652Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4296857Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.4297881Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.4298766Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.4299553Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4300343Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4302161Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4304074Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4305435Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4306340Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4307244Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4308267Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4309464Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.4311017Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.4312369Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.4314270Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4315623Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4316475Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4317361Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4318297Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4319210Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4320436Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4322032Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4324040Z Dec 18 16:01:17    at 
java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
2022-12-18T16:01:17.4324554Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-12-18T16:01:17.4325809Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-12-18T16:01:17.4326453Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-12-18T16:01:17.4326992Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-12-18T16:01:17.4327397Z Dec 18 16:01:17 
2022-12-18T16:01:17.4327909Z Dec 18 16:01:17    at 
org.apache.flink.connector.pulsar.testutils.source.UnorderedSourceTestSuiteBase.checkResultWithSemantic(UnorderedSourceTestSuiteBase.java:55)
2022-12-18T16:01:17.4328668Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:329)
2022-12-18T16:01:17.4329363Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testScaleDown(SourceTestSuiteBase.java:279)
2022-12-18T16:01:17.4329910Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-12-18T16:01:17.4330411Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-12-18T16:01:17.4330982Z Dec 18 16:01:17    at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-12-18T16:01:17.4331484Z Dec 18 16:01:17    at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-12-18T16:01:17.4331997Z Dec 18 16:01:17    at 
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
2022-12-18T16:01:17.4332575Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-12-18T16:01:17.4333220Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-12-18T16:01:17.4334651Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
2022-12-18T16:01:17.4335316Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
2022-12-18T16:01:17.4335968Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
2022-12-18T16:01:17.4337206Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
2022-12-18T16:01:17.4338014Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
2022-12-18T16:01:17.4340260Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-12-18T16:01:17.4361577Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-12-18T16:01:17.4362589Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-12-18T16:01:17.4363905Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-12-18T16:01:17.4364755Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
2022-12-18T16:01:17.4369490Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
2022-12-18T16:01:17.4372628Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
2022-12-18T16:01:17.4373477Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4374141Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
2022-12-18T16:01:17.4375038Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
2022-12-18T16:01:17.4376734Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
2022-12-18T16:01:17.4377822Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.4378654Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4412434Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4413194Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4413831Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4414746Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4415587Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4416208Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4417141Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4418358Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.submit(ForkJoinPoolHierarchicalTestExecutorService.java:118)
2022-12-18T16:01:17.4419599Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2022-12-18T16:01:17.4420831Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2022-12-18T16:01:17.4422062Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
2022-12-18T16:01:17.4422999Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.4424638Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.4425193Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.4425930Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2022-12-18T16:01:17.4426470Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.4427015Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.4429413Z Dec 18 16:01:17    at 
java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
2022-12-18T16:01:17.4429955Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
2022-12-18T16:01:17.4432782Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.4433414Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.4434473Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.4435022Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.4438260Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.4440639Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.4441366Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.4441896Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.4442415Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.4446470Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.4447499Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.4448035Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.4448589Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.4449157Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.4451082Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.4453761Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.4454430Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.4455090Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
2022-12-18T16:01:17.4458151Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.4458815Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4462737Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4463370Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4463970Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4466949Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4467596Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4468217Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4477096Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4478249Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.4495452Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.4496521Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.4497659Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4505788Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4506420Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4507960Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4508875Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4510269Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4511282Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4512743Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4514325Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.4515856Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.4516792Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.4517578Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4518886Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4520127Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4520875Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4521652Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4522765Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4523513Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4524378Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4527602Z Dec 18 16:01:17    at 
java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
2022-12-18T16:01:17.4528144Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-12-18T16:01:17.4528804Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-12-18T16:01:17.4529749Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-12-18T16:01:17.4532285Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-12-18T16:01:17.4532725Z Dec 18 16:01:17 
2022-12-18T16:01:17.4533372Z Dec 18 16:01:17 [ERROR] 
org.apache.flink.tests.util.pulsar.PulsarSourceUnorderedE2ECase.testSavepoint(TestEnvironment,
 DataStreamSourceExternalContext, CheckpointingMode)[1]  Time elapsed: 7.746 s  
<<< FAILURE!
2022-12-18T16:01:17.4534911Z Dec 18 16:01:17 java.lang.AssertionError: 
2022-12-18T16:01:17.4535253Z Dec 18 16:01:17 
2022-12-18T16:01:17.4535927Z Dec 18 16:01:17 Expecting
2022-12-18T16:01:17.4536301Z Dec 18 16:01:17   <CompletableFuture[Failed with 
the following stack trace:
2022-12-18T16:01:17.4537076Z Dec 18 16:01:17 java.lang.RuntimeException: Failed 
to fetch next result
2022-12-18T16:01:17.4537885Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2022-12-18T16:01:17.4538994Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2022-12-18T16:01:17.4540413Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.utils.UnorderedCollectIteratorAssert.compareWithExactlyOnceSemantic(UnorderedCollectIteratorAssert.java:108)
2022-12-18T16:01:17.4541403Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.utils.UnorderedCollectIteratorAssert.matchesRecordsFromSource(UnorderedCollectIteratorAssert.java:79)
2022-12-18T16:01:17.4550324Z Dec 18 16:01:17    at 
org.apache.flink.connector.pulsar.testutils.source.UnorderedSourceTestSuiteBase.lambda$checkResultWithSemantic$0(UnorderedSourceTestSuiteBase.java:53)
2022-12-18T16:01:17.4551120Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2022-12-18T16:01:17.4552980Z Dec 18 16:01:17    at 
java.lang.Thread.run(Thread.java:750)
2022-12-18T16:01:17.4553423Z Dec 18 16:01:17 Caused by: java.io.IOException: 
Failed to fetch job execution result
2022-12-18T16:01:17.4554035Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
2022-12-18T16:01:17.4554921Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
2022-12-18T16:01:17.4556168Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
2022-12-18T16:01:17.4556679Z Dec 18 16:01:17    ... 6 more
2022-12-18T16:01:17.4557451Z Dec 18 16:01:17 Caused by: 
java.util.concurrent.ExecutionException: 
org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 
89bea81c04b959b2a4af661d53e2f8bc)
2022-12-18T16:01:17.4558103Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-12-18T16:01:17.4558635Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2022-12-18T16:01:17.4559912Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
2022-12-18T16:01:17.4560422Z Dec 18 16:01:17    ... 8 more
2022-12-18T16:01:17.4560871Z Dec 18 16:01:17 Caused by: 
org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 
89bea81c04b959b2a4af661d53e2f8bc)
2022-12-18T16:01:17.4562021Z Dec 18 16:01:17    at 
org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:130)
2022-12-18T16:01:17.4562840Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-12-18T16:01:17.4563553Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-12-18T16:01:17.4564138Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.4594784Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-12-18T16:01:17.4597513Z Dec 18 16:01:17    at 
org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:301)
2022-12-18T16:01:17.4600130Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-12-18T16:01:17.4607241Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-12-18T16:01:17.4608096Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.4610465Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-12-18T16:01:17.4612782Z Dec 18 16:01:17    at 
org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$31(RestClusterClient.java:772)
2022-12-18T16:01:17.4614953Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-12-18T16:01:17.4618136Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-12-18T16:01:17.4631360Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.4632040Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-12-18T16:01:17.4632740Z Dec 18 16:01:17    at 
org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:301)
2022-12-18T16:01:17.4633518Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-12-18T16:01:17.4634181Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-12-18T16:01:17.4634838Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.4635384Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
2022-12-18T16:01:17.4635966Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
2022-12-18T16:01:17.4636609Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
2022-12-18T16:01:17.4637241Z Dec 18 16:01:17    at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2022-12-18T16:01:17.4637798Z Dec 18 16:01:17    at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2022-12-18T16:01:17.4638272Z Dec 18 16:01:17    ... 1 more
2022-12-18T16:01:17.4638738Z Dec 18 16:01:17 Caused by: 
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-12-18T16:01:17.4639424Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-12-18T16:01:17.4640138Z Dec 18 16:01:17    at 
org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:128)
2022-12-18T16:01:17.4640711Z Dec 18 16:01:17    ... 24 more
2022-12-18T16:01:17.4641207Z Dec 18 16:01:17 Caused by: 
org.apache.flink.runtime.JobException: Recovery is suppressed by 
NoRestartBackoffTimeStrategy
2022-12-18T16:01:17.4641918Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:139)
2022-12-18T16:01:17.4686605Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:83)
2022-12-18T16:01:17.4687332Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:256)
2022-12-18T16:01:17.4687954Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247)
2022-12-18T16:01:17.4688574Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240)
2022-12-18T16:01:17.4689212Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:739)
2022-12-18T16:01:17.4689856Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:716)
2022-12-18T16:01:17.4690585Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
2022-12-18T16:01:17.4691402Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1622)
2022-12-18T16:01:17.4692079Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1137)
2022-12-18T16:01:17.4692642Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1077)
2022-12-18T16:01:17.4693409Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:916)
2022-12-18T16:01:17.4694111Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionOperations.markFailed(DefaultExecutionOperations.java:43)
2022-12-18T16:01:17.4694794Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.handleTaskDeploymentFailure(DefaultExecutionDeployer.java:327)
2022-12-18T16:01:17.4695576Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignAllResourcesAndRegisterProducedPartitions$2(DefaultExecutionDeployer.java:170)
2022-12-18T16:01:17.4699044Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
2022-12-18T16:01:17.4699620Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
2022-12-18T16:01:17.4700186Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.4700772Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-12-18T16:01:17.4701373Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
2022-12-18T16:01:17.4702047Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:185)
2022-12-18T16:01:17.4702793Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:408)
2022-12-18T16:01:17.4703539Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:396)
2022-12-18T16:01:17.4704239Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:887)
2022-12-18T16:01:17.4704776Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-12-18T16:01:17.4705272Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-12-18T16:01:17.4705838Z Dec 18 16:01:17    at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-12-18T16:01:17.4706350Z Dec 18 16:01:17    at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-12-18T16:01:17.4706876Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$0(AkkaRpcActor.java:301)
2022-12-18T16:01:17.4707531Z Dec 18 16:01:17    at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-12-18T16:01:17.4708171Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:300)
2022-12-18T16:01:17.4708761Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
2022-12-18T16:01:17.4709360Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
2022-12-18T16:01:17.4709954Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
2022-12-18T16:01:17.4710482Z Dec 18 16:01:17    at 
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-12-18T16:01:17.4710963Z Dec 18 16:01:17    at 
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-12-18T16:01:17.4711445Z Dec 18 16:01:17    at 
scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
2022-12-18T16:01:17.4711932Z Dec 18 16:01:17    at 
scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
2022-12-18T16:01:17.4712421Z Dec 18 16:01:17    at 
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-12-18T16:01:17.4712932Z Dec 18 16:01:17    at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
2022-12-18T16:01:17.4713440Z Dec 18 16:01:17    at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
2022-12-18T16:01:17.4714028Z Dec 18 16:01:17    at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
2022-12-18T16:01:17.4714548Z Dec 18 16:01:17    at 
akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-12-18T16:01:17.4714989Z Dec 18 16:01:17    at 
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-12-18T16:01:17.4715452Z Dec 18 16:01:17    at 
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-12-18T16:01:17.4715947Z Dec 18 16:01:17    at 
akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
2022-12-18T16:01:17.4716399Z Dec 18 16:01:17    at 
akka.actor.ActorCell.invoke(ActorCell.scala:547)
2022-12-18T16:01:17.4716845Z Dec 18 16:01:17    at 
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-12-18T16:01:17.4717291Z Dec 18 16:01:17    at 
akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-12-18T16:01:17.4717713Z Dec 18 16:01:17    at 
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-12-18T16:01:17.4718163Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-12-18T16:01:17.4718690Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-12-18T16:01:17.4719222Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-12-18T16:01:17.4719740Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-12-18T16:01:17.4720470Z Dec 18 16:01:17 Caused by: 
java.util.concurrent.CompletionException: 
java.util.concurrent.CompletionException: 
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: 
Could not acquire the minimum required resources.
2022-12-18T16:01:17.4721287Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:227)
2022-12-18T16:01:17.4721786Z Dec 18 16:01:17    ... 39 more
2022-12-18T16:01:17.4722303Z Dec 18 16:01:17 Caused by: 
java.util.concurrent.CompletionException: 
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: 
Could not acquire the minimum required resources.
2022-12-18T16:01:17.4722981Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
2022-12-18T16:01:17.4723554Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
2022-12-18T16:01:17.4724113Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
2022-12-18T16:01:17.4724658Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-12-18T16:01:17.4725290Z Dec 18 16:01:17    ... 37 more
2022-12-18T16:01:17.4725759Z Dec 18 16:01:17 Caused by: 
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: 
Could not acquire the minimum required resources.
2022-12-18T16:01:17.4726202Z Dec 18 16:01:17 ]>
2022-12-18T16:01:17.4726485Z Dec 18 16:01:17 to be completed within 2M.
2022-12-18T16:01:17.4726755Z Dec 18 16:01:17 
2022-12-18T16:01:17.4727232Z Dec 18 16:01:17 exception caught while trying to 
get the future result: java.util.concurrent.ExecutionException: 
java.lang.RuntimeException: Failed to fetch next result
2022-12-18T16:01:17.4727857Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-12-18T16:01:17.4728395Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2022-12-18T16:01:17.4728919Z Dec 18 16:01:17    at 
org.assertj.core.internal.Futures.assertSucceededWithin(Futures.java:109)
2022-12-18T16:01:17.4729534Z Dec 18 16:01:17    at 
org.assertj.core.api.AbstractCompletableFutureAssert.internalSucceedsWithin(AbstractCompletableFutureAssert.java:400)
2022-12-18T16:01:17.4730213Z Dec 18 16:01:17    at 
org.assertj.core.api.AbstractCompletableFutureAssert.succeedsWithin(AbstractCompletableFutureAssert.java:396)
2022-12-18T16:01:17.4730947Z Dec 18 16:01:17    at 
org.apache.flink.connector.pulsar.testutils.source.UnorderedSourceTestSuiteBase.checkResultWithSemantic(UnorderedSourceTestSuiteBase.java:55)
2022-12-18T16:01:17.4731768Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:329)
2022-12-18T16:01:17.4732522Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testSavepoint(SourceTestSuiteBase.java:235)
2022-12-18T16:01:17.4733067Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-12-18T16:01:17.4733558Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-12-18T16:01:17.4734121Z Dec 18 16:01:17    at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-12-18T16:01:17.4734627Z Dec 18 16:01:17    at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-12-18T16:01:17.4735136Z Dec 18 16:01:17    at 
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
2022-12-18T16:01:17.4735719Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-12-18T16:01:17.4736375Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-12-18T16:01:17.4737031Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
2022-12-18T16:01:17.4737646Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
2022-12-18T16:01:17.4738294Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
2022-12-18T16:01:17.4739026Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
2022-12-18T16:01:17.4739794Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
2022-12-18T16:01:17.4740517Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-12-18T16:01:17.4741208Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-12-18T16:01:17.4741873Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-12-18T16:01:17.4742530Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-12-18T16:01:17.4743417Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
2022-12-18T16:01:17.4744225Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
2022-12-18T16:01:17.4744926Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
2022-12-18T16:01:17.4745607Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4746255Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
2022-12-18T16:01:17.4746914Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
2022-12-18T16:01:17.4747567Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
2022-12-18T16:01:17.4748222Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.4748859Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4749611Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4750212Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4750810Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4751458Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4752088Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4752688Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4753426Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4754285Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.submit(ForkJoinPoolHierarchicalTestExecutorService.java:118)
2022-12-18T16:01:17.4755048Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2022-12-18T16:01:17.4755724Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2022-12-18T16:01:17.4756401Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
2022-12-18T16:01:17.4757083Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.4757692Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.4758231Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.4758772Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2022-12-18T16:01:17.4759289Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.4759819Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.4760350Z Dec 18 16:01:17    at 
java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
2022-12-18T16:01:17.4760888Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
2022-12-18T16:01:17.4761413Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.4761970Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.4762513Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.4763033Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.4763582Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.4764140Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.4764718Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.4765681Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.4766214Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.4766749Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.4767358Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.4767945Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.4768480Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.4769040Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.4769583Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.4770096Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.4770690Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.4771353Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
2022-12-18T16:01:17.4772013Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.4772670Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4773319Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4773919Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4774508Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4775165Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4775800Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4776409Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4777152Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4778046Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.4778913Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.4779659Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.4780316Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4780969Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4781563Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4782163Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4782815Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4783434Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4784047Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4784839Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4785784Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.4786645Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.4787396Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.4788048Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4788701Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.4789293Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.4789893Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.4790543Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.4791165Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.4791772Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.4792512Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.4793201Z Dec 18 16:01:17    at 
java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
2022-12-18T16:01:17.4793708Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-12-18T16:01:17.4794234Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-12-18T16:01:17.4794752Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-12-18T16:01:17.4795281Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-12-18T16:01:17.4795767Z Dec 18 16:01:17 Caused by: 
java.lang.RuntimeException: Failed to fetch next result
2022-12-18T16:01:17.4796341Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2022-12-18T16:01:17.4797041Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2022-12-18T16:01:17.4797779Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.utils.UnorderedCollectIteratorAssert.compareWithExactlyOnceSemantic(UnorderedCollectIteratorAssert.java:108)
2022-12-18T16:01:17.4798578Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.utils.UnorderedCollectIteratorAssert.matchesRecordsFromSource(UnorderedCollectIteratorAssert.java:79)
2022-12-18T16:01:17.4799368Z Dec 18 16:01:17    at 
org.apache.flink.connector.pulsar.testutils.source.UnorderedSourceTestSuiteBase.lambda$checkResultWithSemantic$0(UnorderedSourceTestSuiteBase.java:53)
2022-12-18T16:01:17.4800064Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2022-12-18T16:01:17.4800543Z Dec 18 16:01:17    at 
java.lang.Thread.run(Thread.java:750)
2022-12-18T16:01:17.4800956Z Dec 18 16:01:17 Caused by: java.io.IOException: 
Failed to fetch job execution result
2022-12-18T16:01:17.4801589Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
2022-12-18T16:01:17.4802336Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
2022-12-18T16:01:17.4803024Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
2022-12-18T16:01:17.4803511Z Dec 18 16:01:17    ... 6 more
2022-12-18T16:01:17.4807857Z Dec 18 16:01:17 Caused by: 
java.util.concurrent.ExecutionException: 
org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 
89bea81c04b959b2a4af661d53e2f8bc)
2022-12-18T16:01:17.4844052Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-12-18T16:01:17.4847380Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2022-12-18T16:01:17.4852117Z Dec 18 16:01:17    at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
2022-12-18T16:01:17.4876086Z Dec 18 16:01:17    ... 8 more
2022-12-18T16:01:17.4876605Z Dec 18 16:01:17 Caused by: 
org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 
89bea81c04b959b2a4af661d53e2f8bc)
2022-12-18T16:01:17.4887443Z Dec 18 16:01:17    at 
org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:130)
2022-12-18T16:01:17.4893031Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-12-18T16:01:17.4894919Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-12-18T16:01:17.4900794Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.4911188Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-12-18T16:01:17.4912089Z Dec 18 16:01:17    at 
org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:301)
2022-12-18T16:01:17.4917943Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-12-18T16:01:17.5126335Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-12-18T16:01:17.5267191Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.5268242Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-12-18T16:01:17.5276080Z Dec 18 16:01:17    at 
org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$31(RestClusterClient.java:772)
2022-12-18T16:01:17.5281824Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-12-18T16:01:17.5282613Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-12-18T16:01:17.5290340Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.5291214Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-12-18T16:01:17.5292139Z Dec 18 16:01:17    at 
org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:301)
2022-12-18T16:01:17.5298621Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-12-18T16:01:17.5376226Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-12-18T16:01:17.5376873Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.5409485Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
2022-12-18T16:01:17.5416309Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
2022-12-18T16:01:17.5417032Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
2022-12-18T16:01:17.5426365Z Dec 18 16:01:17    at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2022-12-18T16:01:17.5426986Z Dec 18 16:01:17    at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2022-12-18T16:01:17.5427440Z Dec 18 16:01:17    ... 1 more
2022-12-18T16:01:17.5427825Z Dec 18 16:01:17 Caused by: 
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-12-18T16:01:17.5428415Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-12-18T16:01:17.5434016Z Dec 18 16:01:17    at 
org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:128)
2022-12-18T16:01:17.5434606Z Dec 18 16:01:17    ... 24 more
2022-12-18T16:01:17.5435065Z Dec 18 16:01:17 Caused by: 
org.apache.flink.runtime.JobException: Recovery is suppressed by 
NoRestartBackoffTimeStrategy
2022-12-18T16:01:17.5435760Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:139)
2022-12-18T16:01:17.5436518Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:83)
2022-12-18T16:01:17.5437262Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:256)
2022-12-18T16:01:17.5446009Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247)
2022-12-18T16:01:17.5446661Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240)
2022-12-18T16:01:17.5447337Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:739)
2022-12-18T16:01:17.5448018Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:716)
2022-12-18T16:01:17.5448738Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
2022-12-18T16:01:17.5449584Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1622)
2022-12-18T16:01:17.5466185Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1137)
2022-12-18T16:01:17.5466820Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1077)
2022-12-18T16:01:17.5467375Z Dec 18 16:01:17    at 
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:916)
2022-12-18T16:01:17.5468039Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionOperations.markFailed(DefaultExecutionOperations.java:43)
2022-12-18T16:01:17.5468781Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.handleTaskDeploymentFailure(DefaultExecutionDeployer.java:327)
2022-12-18T16:01:17.5469546Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignAllResourcesAndRegisterProducedPartitions$2(DefaultExecutionDeployer.java:170)
2022-12-18T16:01:17.5484448Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
2022-12-18T16:01:17.5485211Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
2022-12-18T16:01:17.5485831Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-12-18T16:01:17.5486402Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-12-18T16:01:17.5487225Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
2022-12-18T16:01:17.5541164Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:185)
2022-12-18T16:01:17.5589909Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:408)
2022-12-18T16:01:17.5590821Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:396)
2022-12-18T16:01:17.5593898Z Dec 18 16:01:17    at 
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:887)
2022-12-18T16:01:17.5594446Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-12-18T16:01:17.5595009Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-12-18T16:01:17.5607573Z Dec 18 16:01:17    at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-12-18T16:01:17.5608134Z Dec 18 16:01:17    at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-12-18T16:01:17.5608720Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$0(AkkaRpcActor.java:301)
2022-12-18T16:01:17.5609416Z Dec 18 16:01:17    at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-12-18T16:01:17.5610172Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:300)
2022-12-18T16:01:17.5610757Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
2022-12-18T16:01:17.5645741Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
2022-12-18T16:01:17.5646467Z Dec 18 16:01:17    at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
2022-12-18T16:01:17.5647041Z Dec 18 16:01:17    at 
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-12-18T16:01:17.5647584Z Dec 18 16:01:17    at 
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-12-18T16:01:17.5648113Z Dec 18 16:01:17    at 
scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
2022-12-18T16:01:17.5648593Z Dec 18 16:01:17    at 
scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
2022-12-18T16:01:17.5665746Z Dec 18 16:01:17    at 
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-12-18T16:01:17.5666345Z Dec 18 16:01:17    at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
2022-12-18T16:01:17.5666851Z Dec 18 16:01:17    at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
2022-12-18T16:01:17.5667398Z Dec 18 16:01:17    at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
2022-12-18T16:01:17.5667930Z Dec 18 16:01:17    at 
akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-12-18T16:01:17.5668372Z Dec 18 16:01:17    at 
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-12-18T16:01:17.5671717Z Dec 18 16:01:17    at 
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-12-18T16:01:17.5672259Z Dec 18 16:01:17    at 
akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
2022-12-18T16:01:17.5672712Z Dec 18 16:01:17    at 
akka.actor.ActorCell.invoke(ActorCell.scala:547)
2022-12-18T16:01:17.5673203Z Dec 18 16:01:17    at 
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-12-18T16:01:17.5675413Z Dec 18 16:01:17    at 
akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-12-18T16:01:17.5704138Z Dec 18 16:01:17    at 
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-12-18T16:01:17.5707108Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-12-18T16:01:17.5707984Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-12-18T16:01:17.5711416Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-12-18T16:01:17.5712096Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-12-18T16:01:17.5715407Z Dec 18 16:01:17 Caused by: 
java.util.concurrent.CompletionException: 
java.util.concurrent.CompletionException: 
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: 
Could not acquire the minimum required resources.
2022-12-18T16:01:17.5725703Z Dec 18 16:01:17    at 
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:227)
2022-12-18T16:01:17.5726418Z Dec 18 16:01:17    ... 39 more
2022-12-18T16:01:17.5728525Z Dec 18 16:01:17 Caused by: 
java.util.concurrent.CompletionException: 
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: 
Could not acquire the minimum required resources.
2022-12-18T16:01:17.5729444Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
2022-12-18T16:01:17.5732883Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
2022-12-18T16:01:17.5733508Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
2022-12-18T16:01:17.5734065Z Dec 18 16:01:17    at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-12-18T16:01:17.5734532Z Dec 18 16:01:17    ... 37 more
2022-12-18T16:01:17.5737670Z Dec 18 16:01:17 Caused by: 
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: 
Could not acquire the minimum required resources.
2022-12-18T16:01:17.5738151Z Dec 18 16:01:17 
2022-12-18T16:01:17.5738718Z Dec 18 16:01:17    at 
org.apache.flink.connector.pulsar.testutils.source.UnorderedSourceTestSuiteBase.checkResultWithSemantic(UnorderedSourceTestSuiteBase.java:55)
2022-12-18T16:01:17.5739519Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:329)
2022-12-18T16:01:17.5740217Z Dec 18 16:01:17    at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testSavepoint(SourceTestSuiteBase.java:235)
2022-12-18T16:01:17.5740814Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-12-18T16:01:17.5743788Z Dec 18 16:01:17    at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-12-18T16:01:17.5744368Z Dec 18 16:01:17    at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-12-18T16:01:17.5744923Z Dec 18 16:01:17    at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-12-18T16:01:17.5745475Z Dec 18 16:01:17    at 
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
2022-12-18T16:01:17.5746097Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-12-18T16:01:17.5746755Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-12-18T16:01:17.5750416Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
2022-12-18T16:01:17.5751142Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
2022-12-18T16:01:17.5751978Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
2022-12-18T16:01:17.5752861Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
2022-12-18T16:01:17.5753709Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
2022-12-18T16:01:17.5758014Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-12-18T16:01:17.5758910Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-12-18T16:01:17.5760792Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-12-18T16:01:17.5761606Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-12-18T16:01:17.5762370Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
2022-12-18T16:01:17.5763112Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
2022-12-18T16:01:17.5769118Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
2022-12-18T16:01:17.5769877Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5770641Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
2022-12-18T16:01:17.5771429Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
2022-12-18T16:01:17.5772124Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
2022-12-18T16:01:17.5775778Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.5780089Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5780867Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.5782542Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.5786991Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.5787767Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5788501Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.5790549Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.5791401Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.5795013Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.submit(ForkJoinPoolHierarchicalTestExecutorService.java:118)
2022-12-18T16:01:17.5795865Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2022-12-18T16:01:17.5798384Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2022-12-18T16:01:17.5799183Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
2022-12-18T16:01:17.5805898Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.5810158Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.5810955Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.5818304Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2022-12-18T16:01:17.5831061Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-12-18T16:01:17.5846994Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-12-18T16:01:17.5847532Z Dec 18 16:01:17    at 
java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
2022-12-18T16:01:17.5851878Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
2022-12-18T16:01:17.5854465Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.5855039Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.5855698Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.5858114Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.5863006Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.5864095Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.5866455Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.5867385Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.5870494Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-12-18T16:01:17.5871159Z Dec 18 16:01:17    at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-12-18T16:01:17.5873380Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-12-18T16:01:17.5874214Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-12-18T16:01:17.5874827Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-12-18T16:01:17.5876927Z Dec 18 16:01:17    at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-12-18T16:01:17.5881873Z Dec 18 16:01:17    at 
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-12-18T16:01:17.5883444Z Dec 18 16:01:17    at 
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-12-18T16:01:17.5884079Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
2022-12-18T16:01:17.5884815Z Dec 18 16:01:17    at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
2022-12-18T16:01:17.5885873Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-12-18T16:01:17.5890797Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5891506Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.5892305Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.5892976Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.5895690Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5896418Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.5899616Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.5901162Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.5902108Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.5903046Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.5907124Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.5908401Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5909105Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.5909783Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.5911367Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.5914696Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5915500Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.5916118Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.5916903Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.5919986Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-12-18T16:01:17.5920915Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-12-18T16:01:17.5921662Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-12-18T16:01:17.5922357Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5923042Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-12-18T16:01:17.5923648Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-12-18T16:01:17.5926362Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-12-18T16:01:17.5927074Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-12-18T16:01:17.5927705Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-12-18T16:01:17.5928360Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-12-18T16:01:17.5929180Z Dec 18 16:01:17    at 
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-12-18T16:01:17.5932489Z Dec 18 16:01:17    at 
java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
2022-12-18T16:01:17.5933287Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-12-18T16:01:17.5933965Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-12-18T16:01:17.5934572Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-12-18T16:01:17.5935138Z Dec 18 16:01:17    at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-12-18T16:01:17.5935601Z Dec 18 16:01:17 
{code}

in 
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=44045&view=logs&j=af184cdd-c6d8-5084-0b69-7e9c67b35f7a&t=160c9ae5-96fd-516e-1c91-deb81f59292a

> PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing 
> TaskManagers
> ---------------------------------------------------------------------------------
>
>                 Key: FLINK-29755
>                 URL: https://issues.apache.org/jira/browse/FLINK-29755
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Pulsar
>    Affects Versions: 1.16.0, 1.17.0
>            Reporter: Matthias Pohl
>            Priority: Critical
>              Labels: test-stability
>         Attachments: PulsarSourceUnorderedE2ECase.testSavepoint.log
>
>
> [This 
> build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42325&view=logs&j=af184cdd-c6d8-5084-0b69-7e9c67b35f7a&t=160c9ae5-96fd-516e-1c91-deb81f59292a&l=13932]
>  failed (not exclusively) due to a problem with 
> {{PulsarSourceUnorderedE2ECase.testSavepoint}}. It seems like there were no 
> TaskManagers spun up which resulted in the test job failing with a 
> {{NoResourceAvailableException}}.
> {code}
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge [] - 
> Could not acquire the minimum required resources, failing slot requests. 
> Acquired: []. Current slot pool status: Registered TMs: 0, registered slots: 
> 0 free slots: 0
> {code}
> I didn't raise this one to critical because it looks like a missing 
> TaskManager test environment issue. I attached the e2e test-specific logs to 
> the Jira issue.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)