Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Cannot Reproduce
-
ml-2.0.0
-
None
Description
2022-05-19T10:17:34.1561772Z [ERROR] testBroadcastWithMultipleChain[0] Time elapsed: 3.084 s <<< ERROR! 2022-05-19T10:17:34.1562657Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.1563188Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.1563788Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.1564309Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.1564811Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.1565264Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1565723Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1566463Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.1566976Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1567447Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1567917Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1568439Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1568892Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.1569401Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.1570217Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.1570905Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.1571490Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1571961Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1572516Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1572944Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1573411Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.1573811Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.1574109Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.1574425Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.1574739Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.1575076Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1575529Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.1576024Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.1576506Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.1576900Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.1577299Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.1577654Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.1578036Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.1578451Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.1578817Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.1579159Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.1579498Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.1579851Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1580423Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.1580852Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1581220Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.1581581Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.1581971Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1582426Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.1582863Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.1583316Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.1583704Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.1584169Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.1584590Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.1585046Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.1585679Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.1586513Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.1587246Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.1587843Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.1588501Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.1589135Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.1589750Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.1590307Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.1590748Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 2022-05-19T10:17:34.1591168Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 2022-05-19T10:17:34.1591636Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.1592038Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.1592435Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.1593044Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.1593765Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.1594276Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.1594792Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.1595314Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.1595731Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.1596069Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.1596421Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.1596776Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.1597145Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.1597506Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.1598024Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1598384Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1598698Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.1599000Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.1599391Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.1599734Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.1600051Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.1600374Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.1600687Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.1600965Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.1601193Z ... 4 more 2022-05-19T10:17:34.1601479Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.1601800Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.1602099Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.1602360Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.1602605Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.1603051Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.1603574Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.1604012Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.1606969Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.1607524Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.1608111Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.1608741Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.1609408Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.1610123Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.1631398Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1653097Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.1653562Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.1653934Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.1654253Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.1654641Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1655170Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.1655713Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.1656175Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.1656669Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1657149Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.1657464Z ... 3 more 2022-05-19T10:17:34.1657766Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1658085Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.1658366Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.1658665Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.1659103Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.1659651Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.1660257Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.1661048Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.1661682Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.1677929Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.1678593Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.1679166Z ... 7 more 2022-05-19T10:17:34.1679283Z 2022-05-19T10:17:34.1679435Z [ERROR] testBroadcastWithMixedOutput[0] Time elapsed: 1.337 s <<< ERROR! 2022-05-19T10:17:34.1679825Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.1680312Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.1680990Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.1681497Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.1681922Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.1682360Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1682790Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1683291Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.1683969Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1684438Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1684878Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1685329Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1685770Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.1686278Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.1686891Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.1687582Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.1688161Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1688633Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1689074Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1689524Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1690204Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.1690603Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.1690922Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.1691512Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.1691844Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.1692183Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1692663Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.1693177Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.1693593Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.1694124Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.1694571Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.1695318Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.1695698Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.1697316Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.1697711Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.1698048Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.1698420Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.1698785Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1699192Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.1699606Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1699997Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.1702741Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.1703133Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1703533Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.1703989Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.1704440Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.1704811Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.1705209Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.1705629Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.1706070Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.1706708Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.1707553Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.1708287Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.1708869Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.1709524Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.1710169Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.1710749Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.1711296Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.1711745Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.1712178Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.1712573Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.1712971Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.1713572Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.1714183Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.1714859Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.1715407Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.1715939Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.1716371Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.1716777Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.1717145Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.1717508Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.1717879Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.1718260Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.1718626Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1718986Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1719301Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.1719606Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.1719945Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.1720286Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.1720606Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.1720925Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.1721223Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.1721511Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.1721741Z ... 4 more 2022-05-19T10:17:34.1721985Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.1722304Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.1722599Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.1722854Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.1723094Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.1723538Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.1724057Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.1724487Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.1725061Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.1725586Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.1726138Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.1726750Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.1727391Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.1727905Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.1728388Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1728851Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.1729258Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.1729621Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.1774584Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.1775089Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1775806Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.1776502Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.1776954Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.1777451Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1778016Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.1778320Z ... 3 more 2022-05-19T10:17:34.1778629Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1778956Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.1779242Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.1779529Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.1779973Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.1780540Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.1781128Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.1781746Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.1782391Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.1783004Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.1783568Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.1783954Z ... 7 more 2022-05-19T10:17:34.1784067Z 2022-05-19T10:17:34.1784266Z [ERROR] testBroadcastWithMixedOutputWithSideOutput[0] Time elapsed: 1.396 s <<< ERROR! 2022-05-19T10:17:34.1784696Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.1785155Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.1785726Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.1786254Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.1786676Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.1789034Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1789503Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1790015Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.1790674Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1791145Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1791604Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1792058Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1792496Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.1793005Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.1793635Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.1794327Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.1795026Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1795496Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1795955Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1796396Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1796929Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.1797343Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.1797667Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.1797976Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.1798402Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.1798744Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1799196Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.1799695Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.1800113Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.1800520Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.1800905Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.1801262Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.1801641Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.1802051Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.1802421Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.1802856Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.1803189Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.1803683Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1804076Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.1804494Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1805028Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.1805394Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.1805782Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1806164Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.1806609Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.1807065Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.1807449Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.1807827Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.1808246Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.1808699Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.1809335Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.1843823Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.1844818Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.1845425Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.1846087Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.1846722Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.1847372Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.1847929Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.1848388Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.1848811Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.1849209Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.1849623Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.1850411Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.1851026Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.1851553Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.1855271Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.1855806Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.1856242Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.1856606Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.1856971Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.1857336Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.1857720Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.1858109Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.1858457Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1858824Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1859149Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.1859436Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.1859772Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.1860126Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.1860450Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.1860760Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.1861073Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.1861360Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.1861575Z ... 4 more 2022-05-19T10:17:34.1861817Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.1862143Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.1862433Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.1862691Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.1862953Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.1863384Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.1863904Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.1864345Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.1864975Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.1865504Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.1866072Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.1866716Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.1867435Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.1867953Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.1868450Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1868941Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.1869347Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.1869732Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.1870047Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.1870422Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1870944Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.1871485Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.1871943Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.1872427Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1872902Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.1873213Z ... 3 more 2022-05-19T10:17:34.1873514Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1873827Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.1874108Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.1874403Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.1874825Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.1875389Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.1875990Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.1876601Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.1877219Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.1877830Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.1878404Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.1878779Z ... 7 more 2022-05-19T10:17:34.1878875Z 2022-05-19T10:17:34.1879072Z [ERROR] testBroadcastWithMultipleResultPartitions[0] Time elapsed: 1.674 s <<< ERROR! 2022-05-19T10:17:34.1879496Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.1879969Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.1880525Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.1881051Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.1881540Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.1881987Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1882420Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1882926Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.1883485Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1883956Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1884397Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1884846Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1901846Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.1902395Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.1903016Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.1903712Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.1904295Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1904763Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1905212Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1905658Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1906127Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.1906528Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.1906849Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.1907168Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.1907484Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.1907816Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1908419Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.1908917Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.1909319Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.1909722Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.1910122Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.1910478Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.1910840Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.1911263Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.1911623Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.1911946Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.1912296Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.1912642Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1913031Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.1913429Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1913949Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.1914302Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.1914668Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1915035Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.1915543Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.1915983Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.1916344Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.1916726Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.1917133Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.1917569Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.1918190Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.1919005Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.1919721Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.1945115Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.1945880Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.1946538Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.1947122Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.1947674Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.1948126Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.1948555Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.1948949Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.1949350Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.1949951Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.1950561Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.1951068Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.1951620Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.1952156Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.1952970Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.1953334Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.1953703Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.1954066Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.1954430Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.1954809Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.1955168Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1955530Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.1956010Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.1956310Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.1956649Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.1956991Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.1957309Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.1957629Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.1957988Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.1958279Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.1958502Z ... 4 more 2022-05-19T10:17:34.1958747Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.1959060Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.1959356Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.1959619Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.1959868Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.1960314Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.1960840Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.1961268Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.1961947Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.1962447Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.1962965Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.1963719Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.1964359Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.1964876Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.1965358Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1965817Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.1966216Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.1966580Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.1966866Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.1967229Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1967989Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.1968531Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.1968973Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.1969456Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.1970176Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.1970494Z ... 3 more 2022-05-19T10:17:34.1970787Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.1971125Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.1971407Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.1971689Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.1972140Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.1972702Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.1973364Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.1973983Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.1974616Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.1975273Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.1975838Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.1976216Z ... 7 more 2022-05-19T10:17:34.1976325Z 2022-05-19T10:17:34.1976492Z [ERROR] testBroadcastWithResultPartition[0] Time elapsed: 1.802 s <<< ERROR! 2022-05-19T10:17:34.1976885Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.1977343Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.1977914Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.1978436Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.1978866Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.1979299Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1979744Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1980247Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.1980751Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1981219Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1981784Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1982218Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1982636Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.1983124Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.1983732Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.1984401Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.1984943Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.1985500Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.1985923Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.1986524Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.1986978Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.1987373Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.1987846Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.1988154Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.1988476Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.1988819Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1989286Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.1989845Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.1990272Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.1990686Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.1991078Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.1991441Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.1991871Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.1992300Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.1992675Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.1993017Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.1993378Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.1993724Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.1994125Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.1994552Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1994919Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.1995285Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.1995669Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.1996047Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.1996485Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.1996926Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.1997305Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.1997681Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.1998093Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.1998542Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.1999185Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2000014Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2000748Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2001338Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2001996Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2002625Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2003197Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2003748Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2004204Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2004620Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2005009Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2005413Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2006051Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2006657Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2007293Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2007819Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2008368Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2008787Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2009139Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2009476Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2009991Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2013006Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2013534Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2013885Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2014237Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2014559Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2014843Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2015342Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2015693Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2016006Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2016313Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2016624Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2016911Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2017122Z ... 4 more 2022-05-19T10:17:34.2017361Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2017693Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2017975Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2018229Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2018481Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2018913Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2019435Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2019872Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2020340Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2020868Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2021432Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2022065Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2022720Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2023229Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2023722Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2024208Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2024607Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2024980Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2025440Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2025590Z 2022-05-19T10:17:34.2025734Z [ERROR] testBroadcastWithChain[0] Time elapsed: 1.868 s <<< ERROR! 2022-05-19T10:17:34.2026099Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.2026571Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.2027139Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.2027725Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.2028151Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.2028598Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2029046Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2029657Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.2030163Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2030617Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2031066Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2031492Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2031927Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.2032674Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.2033274Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.2033945Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.2034685Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2035152Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2035594Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2036042Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2036515Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.2036927Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.2037230Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.2037549Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.2037869Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.2038205Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2038685Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.2039325Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.2039912Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.2040372Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.2040789Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.2041200Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.2041574Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.2042012Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.2042455Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.2042804Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.2043153Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.2043864Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2044279Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.2044747Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2045135Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.2045501Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.2045889Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2046260Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.2046705Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.2047144Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.2047513Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.2047909Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.2048328Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.2048783Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.2049407Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2050435Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2051179Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2051776Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2052421Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2053067Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2053647Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2054195Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2054640Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2055071Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2055475Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2055867Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2056472Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2057079Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2057600Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2058129Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2058658Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2059081Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2059510Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2059864Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2060230Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2060611Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2060977Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2061339Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2061744Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2062062Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2062355Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2062687Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2063043Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2063348Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2063667Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2063976Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2064247Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2064470Z ... 4 more 2022-05-19T10:17:34.2064707Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2065020Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2065316Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2065569Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2065808Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2066282Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2066838Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2067286Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2067744Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2068282Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2068853Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2069502Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2070148Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2070677Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2071186Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2071665Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2072079Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2072452Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2072758Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2073120Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2073659Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.2074194Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.2074651Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.2075123Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2075607Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.2075964Z ... 3 more 2022-05-19T10:17:34.2076254Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2076577Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.2076855Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.2077141Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.2077619Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.2078181Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.2078777Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.2079375Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.2080006Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.2080612Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.2081185Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.2081554Z ... 7 more 2022-05-19T10:17:34.2081664Z 2022-05-19T10:17:34.2081833Z [ERROR] testBroadcastWithMultipleChain[1] Time elapsed: 2.042 s <<< ERROR! 2022-05-19T10:17:34.2082223Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.2082680Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.2083245Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.2083768Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.2084199Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.2084631Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2085078Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2085582Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.2086101Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2086551Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2087007Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2087453Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2087913Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.2088403Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.2089026Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.2089713Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.2090399Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2090852Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2091308Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2091759Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2092283Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.2092696Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.2093015Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.2093454Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.2093754Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.2094090Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2094600Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.2095191Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.2095760Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.2096166Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.2096564Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.2096904Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.2097279Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.2097700Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.2098062Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.2098394Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.2098746Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.2099101Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2099477Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.2099890Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2100431Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.2100792Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.2101162Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2101537Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.2101991Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.2102424Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.2102807Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.2103257Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.2103679Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.2104124Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.2104759Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2105600Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2106364Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2106943Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2107593Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2108239Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2108855Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2109408Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2109860Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2110288Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2110670Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2111122Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2111728Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2112346Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2112852Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2113396Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2113927Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2114338Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2114696Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2115057Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2115419Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2115789Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2116173Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2116532Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2116876Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2117204Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2117502Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2117838Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2118180Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2118494Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2118816Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2119115Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2119404Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2119632Z ... 4 more 2022-05-19T10:17:34.2119863Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2120312Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2120605Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2120842Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2121088Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2121517Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2122027Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2122440Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2122896Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2123418Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2123954Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2124575Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2125260Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2125777Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2126248Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2126721Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2127122Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2127524Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2127811Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2128173Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2128694Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.2129202Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.2129643Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.2130321Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2130801Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.2131085Z ... 3 more 2022-05-19T10:17:34.2131380Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2131700Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.2131962Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.2132255Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.2132683Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.2133229Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.2133801Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.2134395Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.2135006Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.2135597Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.2136139Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.2136503Z ... 7 more 2022-05-19T10:17:34.2136609Z 2022-05-19T10:17:34.2136765Z [ERROR] testBroadcastWithMixedOutput[1] Time elapsed: 1.879 s <<< ERROR! 2022-05-19T10:17:34.2137131Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.2137590Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.2138143Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.2138650Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.2139060Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.2139496Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2139932Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2140412Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.2141027Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2141530Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2141948Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2142347Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2142761Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.2143461Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.2144417Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.2145059Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.2145591Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2146026Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2146446Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2146845Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2147279Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.2147657Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.2147941Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.2148239Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.2148532Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.2148841Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2149278Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.2149749Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.2150144Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.2150683Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.2151084Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.2151604Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.2152019Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.2152481Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.2152923Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.2153339Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.2153728Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.2154327Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2154752Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.2155247Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2155701Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.2156106Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.2156602Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2157056Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.2157572Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.2158147Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.2158627Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.2159090Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.2159530Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.2160067Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.2160838Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2161786Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2162542Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2163220Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2163946Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2164690Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2165289Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2165917Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2166450Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2166956Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2167452Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2167932Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2168620Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2169259Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2170019Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2170679Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2171294Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2171743Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2172175Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2172653Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2173039Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2173504Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2173963Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2174403Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2174932Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2175324Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2175683Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2176045Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2176460Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2176924Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2177421Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2177803Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2178270Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2178613Z ... 4 more 2022-05-19T10:17:34.2178880Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2179282Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2203623Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2203977Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2204228Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2204830Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2205366Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2205814Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2206278Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2206831Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2207406Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2208049Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2208689Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2209221Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2209723Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2210389Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2210813Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2211191Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2211510Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2211875Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2212421Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.2212959Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.2213423Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.2213893Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2214380Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.2214688Z ... 3 more 2022-05-19T10:17:34.2214975Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2215313Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.2215592Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.2215875Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.2216312Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.2216871Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.2217478Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.2218079Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.2218704Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.2219311Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.2219968Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.2220334Z ... 7 more 2022-05-19T10:17:34.2220441Z 2022-05-19T10:17:34.2220639Z [ERROR] testBroadcastWithMixedOutputWithSideOutput[1] Time elapsed: 1.831 s <<< ERROR! 2022-05-19T10:17:34.2221066Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.2221585Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.2222157Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.2222680Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.2223114Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.2223548Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2224002Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2224507Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.2225040Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2225491Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2225951Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2226399Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2226828Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.2227331Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.2227957Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.2228650Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.2229213Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2229683Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2230140Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2230590Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2231048Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.2231456Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.2231780Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.2232089Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.2232409Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.2232752Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2233232Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.2233727Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.2234159Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.2234578Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.2234970Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.2235333Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.2235780Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.2236223Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.2236580Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.2236923Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.2237288Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.2237682Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2238088Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.2238514Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2238904Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.2239255Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.2239634Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2240004Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.2240437Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.2240879Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.2241304Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.2241701Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.2242105Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.2242560Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.2243203Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2244046Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2244764Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2245707Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2246372Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2247021Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2247585Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2247847Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2248024Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2248259Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2248400Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2248655Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2248995Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2249240Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2249485Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2249839Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2250075Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2250336Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2250506Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2250682Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2250855Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2251030Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2251269Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2251438Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2251603Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2251741Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2251881Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2252059Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2252217Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2252340Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2252499Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2252631Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2252764Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2252834Z ... 4 more 2022-05-19T10:17:34.2252985Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2253146Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2253269Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2253369Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2253488Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2253788Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2253993Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2254212Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2254448Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2254735Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2255001Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2255345Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2255631Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2255854Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2256111Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2256324Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2256503Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2256675Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2256791Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2257029Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2257309Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.2257536Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.2257746Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.2258047Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2258261Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.2258331Z ... 3 more 2022-05-19T10:17:34.2258530Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2258646Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.2258818Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.2258954Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.2259226Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.2259499Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.2259810Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.2260096Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.2260421Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.2260692Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.2260982Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.2261039Z ... 7 more 2022-05-19T10:17:34.2261048Z 2022-05-19T10:17:34.2261242Z [ERROR] testBroadcastWithMultipleResultPartitions[1] Time elapsed: 1.83 s <<< ERROR! 2022-05-19T10:17:34.2261451Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.2261697Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.2261999Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.2262215Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.2262420Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.2262644Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2262854Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2263116Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.2263344Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2263559Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2263777Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2263987Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2264200Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.2264469Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.2264805Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.2265146Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.2265363Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2265579Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2265799Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2266051Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2266290Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.2266436Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.2266582Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.2266732Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.2266913Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.2267092Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2267370Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.2267585Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.2267779Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.2267981Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.2268168Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.2268321Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.2268531Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.2268730Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.2268879Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.2269051Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.2269216Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.2269390Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2269596Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.2269791Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2269954Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.2270115Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.2270306Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2270473Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.2270729Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.2270902Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.2271086Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.2271271Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.2271477Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.2271690Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.2272080Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2272524Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2272804Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2273104Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2273445Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2273777Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2274051Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2274309Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2274481Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2274742Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2274887Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2275131Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2275469Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2275729Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2275974Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2276254Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2276488Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2276645Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2276814Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2276983Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2277148Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2277332Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2277502Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2277670Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2277836Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2277960Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2278096Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2278267Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2278427Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2278563Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2278822Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2278947Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2279234Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2279291Z ... 4 more 2022-05-19T10:17:34.2279431Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2279595Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2279712Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2279825Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2279938Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2280239Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2280442Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2280647Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2280880Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2281166Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2281432Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2281831Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2282117Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2282340Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2282594Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2282855Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2283023Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2283196Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2283311Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2283543Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2283838Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.2284064Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.2284273Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.2284525Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2284728Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.2284797Z ... 3 more 2022-05-19T10:17:34.2284996Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2285111Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.2285250Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.2285385Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.2285662Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.2285931Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.2286229Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.2286516Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.2286842Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.2287106Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.2287398Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.2287469Z ... 7 more 2022-05-19T10:17:34.2287477Z 2022-05-19T10:17:34.2287646Z [ERROR] testBroadcastWithResultPartition[1] Time elapsed: 1.95 s <<< ERROR! 2022-05-19T10:17:34.2287852Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.2288097Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.2288387Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.2288595Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.2288800Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.2289018Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2289226Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2289501Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.2290086Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2290310Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2290529Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2290722Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2290990Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.2291267Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.2291612Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.2291952Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.2292183Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2292397Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2292618Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2292824Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2293056Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.2293211Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.2293358Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.2293506Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.2293656Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.2293835Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2294115Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.2294333Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.2294509Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.2294721Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.2294908Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.2295064Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.2295276Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.2295484Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.2295634Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.2295807Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.2295980Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.2296140Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2296345Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.2296551Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2296715Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.2296887Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.2297077Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2297305Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.2297561Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.2297723Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.2297911Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.2298098Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.2298349Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.2298579Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.2298970Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2299422Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2299704Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2300002Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2300329Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2300619Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2300894Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2301158Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2301330Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2301564Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2301709Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2301955Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2302293Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2302536Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2302785Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2303065Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2303303Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2303475Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2303641Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2303813Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2303981Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2304155Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2304323Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2304489Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2304655Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2304790Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2304927Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2305099Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2305257Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2305425Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2305584Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2305715Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2305848Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2305918Z ... 4 more 2022-05-19T10:17:34.2306062Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2306222Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2306337Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2306480Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2306598Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2306897Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2307101Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2307316Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2307552Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2307837Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2308100Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2308446Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2308737Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2308962Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2309221Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2309439Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2309617Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2309791Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2309899Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2309908Z 2022-05-19T10:17:34.2310051Z [ERROR] testBroadcastWithChain[1] Time elapsed: 1.332 s <<< ERROR! 2022-05-19T10:17:34.2310244Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2022-05-19T10:17:34.2310487Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2022-05-19T10:17:34.2310786Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2022-05-19T10:17:34.2310994Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2022-05-19T10:17:34.2311199Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2022-05-19T10:17:34.2311420Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2311629Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2311909Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2022-05-19T10:17:34.2312139Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2312345Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2312564Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2312770Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2312985Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2022-05-19T10:17:34.2313252Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2022-05-19T10:17:34.2313675Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2022-05-19T10:17:34.2314011Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2022-05-19T10:17:34.2314241Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2022-05-19T10:17:34.2314494Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2022-05-19T10:17:34.2314703Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2022-05-19T10:17:34.2314911Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2022-05-19T10:17:34.2315152Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2022-05-19T10:17:34.2315309Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2022-05-19T10:17:34.2315459Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2022-05-19T10:17:34.2315610Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2022-05-19T10:17:34.2315760Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2022-05-19T10:17:34.2315936Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2316208Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2022-05-19T10:17:34.2316426Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2022-05-19T10:17:34.2316620Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2022-05-19T10:17:34.2316822Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2022-05-19T10:17:34.2317012Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2022-05-19T10:17:34.2317171Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2022-05-19T10:17:34.2317387Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2022-05-19T10:17:34.2317601Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2022-05-19T10:17:34.2317751Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2022-05-19T10:17:34.2317909Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2022-05-19T10:17:34.2318077Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2022-05-19T10:17:34.2318249Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2022-05-19T10:17:34.2318452Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2022-05-19T10:17:34.2318654Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2318820Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2022-05-19T10:17:34.2318995Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2022-05-19T10:17:34.2319185Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2022-05-19T10:17:34.2319340Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2022-05-19T10:17:34.2319597Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2022-05-19T10:17:34.2319774Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2022-05-19T10:17:34.2319958Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2022-05-19T10:17:34.2320142Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2022-05-19T10:17:34.2320345Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2022-05-19T10:17:34.2320567Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy 2022-05-19T10:17:34.2321002Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2022-05-19T10:17:34.2321443Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2022-05-19T10:17:34.2321709Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2022-05-19T10:17:34.2322048Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2022-05-19T10:17:34.2322389Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2022-05-19T10:17:34.2322676Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) 2022-05-19T10:17:34.2322950Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2022-05-19T10:17:34.2323212Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) 2022-05-19T10:17:34.2323382Z at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) 2022-05-19T10:17:34.2323736Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-05-19T10:17:34.2323872Z at java.lang.reflect.Method.invoke(Method.java:498) 2022-05-19T10:17:34.2324096Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2022-05-19T10:17:34.2324427Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2022-05-19T10:17:34.2324678Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2022-05-19T10:17:34.2324915Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2022-05-19T10:17:34.2325355Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2022-05-19T10:17:34.2325595Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2022-05-19T10:17:34.2325768Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2022-05-19T10:17:34.2325934Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2022-05-19T10:17:34.2326090Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2022-05-19T10:17:34.2326256Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2022-05-19T10:17:34.2326445Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2022-05-19T10:17:34.2326613Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2022-05-19T10:17:34.2326778Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2326942Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2022-05-19T10:17:34.2327079Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2022-05-19T10:17:34.2327221Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2022-05-19T10:17:34.2327382Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2022-05-19T10:17:34.2327538Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2022-05-19T10:17:34.2327674Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2022-05-19T10:17:34.2327832Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2022-05-19T10:17:34.2327966Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2022-05-19T10:17:34.2328095Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2022-05-19T10:17:34.2328168Z ... 4 more 2022-05-19T10:17:34.2328310Z Caused by: java.lang.IllegalThreadStateException 2022-05-19T10:17:34.2328458Z at java.lang.ThreadGroup.addUnstarted(ThreadGroup.java:867) 2022-05-19T10:17:34.2328571Z at java.lang.Thread.init(Thread.java:407) 2022-05-19T10:17:34.2328685Z at java.lang.Thread.init(Thread.java:351) 2022-05-19T10:17:34.2328798Z at java.lang.Thread.<init>(Thread.java:601) 2022-05-19T10:17:34.2329146Z at org.apache.flink.runtime.taskmanager.DispatcherThreadFactory.newThread(DispatcherThreadFactory.java:48) 2022-05-19T10:17:34.2329349Z at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619) 2022-05-19T10:17:34.2329566Z at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) 2022-05-19T10:17:34.2329908Z at java.util.concurrent.ThreadPoolExecutor.ensurePrestart(ThreadPoolExecutor.java:1603) 2022-05-19T10:17:34.2330238Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:334) 2022-05-19T10:17:34.2330510Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2022-05-19T10:17:34.2330871Z at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.registerTimer(SystemProcessingTimeService.java:112) 2022-05-19T10:17:34.2331160Z at org.apache.flink.streaming.runtime.tasks.StreamTask.scheduleBufferDebloater(StreamTask.java:779) 2022-05-19T10:17:34.2331389Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:758) 2022-05-19T10:17:34.2331645Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2331857Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) 2022-05-19T10:17:34.2332038Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) 2022-05-19T10:17:34.2332197Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) 2022-05-19T10:17:34.2332311Z at java.lang.Thread.run(Thread.java:750) 2022-05-19T10:17:34.2332546Z Suppressed: java.lang.Exception: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2332838Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1024) 2022-05-19T10:17:34.2333072Z at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928) 2022-05-19T10:17:34.2333280Z at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940) 2022-05-19T10:17:34.2333536Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) 2022-05-19T10:17:34.2333758Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) 2022-05-19T10:17:34.2333830Z ... 3 more 2022-05-19T10:17:34.2334016Z Caused by: java.lang.AssertionError: Number of received records does not consistent expected:<100> but was:<0> 2022-05-19T10:17:34.2334132Z at org.junit.Assert.fail(Assert.java:89) 2022-05-19T10:17:34.2334273Z at org.junit.Assert.failNotEquals(Assert.java:835) 2022-05-19T10:17:34.2334406Z at org.junit.Assert.assertEquals(Assert.java:647) 2022-05-19T10:17:34.2334679Z at org.apache.flink.iteration.broadcast.BroadcastOutputTest$CheckResultSink.close(BroadcastOutputTest.java:239) 2022-05-19T10:17:34.2334949Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) 2022-05-19T10:17:34.2335260Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) 2022-05-19T10:17:34.2335544Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) 2022-05-19T10:17:34.2335859Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) 2022-05-19T10:17:34.2336123Z at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035) 2022-05-19T10:17:34.2336411Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021) 2022-05-19T10:17:34.2336479Z ... 7 more 2022-05-19T10:17:34.2336487Z 2022-05-19T10:17:34.2336762Z [INFO] Running org.apache.flink.iteration.compile.DraftExecutionEnvironmentSwitchWrapperTest 2022-05-19T10:17:34.2339417Z [INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 s - in org.apache.flink.iteration.compile.DraftExecutionEnvironmentSwitchWrapperTest 2022-05-19T10:17:34.2339808Z [INFO] Running org.apache.flink.iteration.IterationConstructionTest 2022-05-19T10:17:34.3146359Z [INFO] Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.115 s - in org.apache.flink.iteration.IterationConstructionTest 2022-05-19T10:17:34.3146820Z [INFO] Running org.apache.flink.iteration.progresstrack.OperatorEpochWatermarkTrackerTest 2022-05-19T10:17:34.3161293Z [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 s - in org.apache.flink.iteration.progresstrack.OperatorEpochWatermarkTrackerTest 2022-05-19T10:17:34.6772965Z [INFO] 2022-05-19T10:17:34.6773333Z [INFO] Results: 2022-05-19T10:17:34.6773597Z [INFO] 2022-05-19T10:17:34.6773787Z [ERROR] Errors: 2022-05-19T10:17:34.6774912Z [ERROR] BroadcastOutputTest.testBroadcastWithChain » JobExecution Job execution failed... 2022-05-19T10:17:34.6775568Z [ERROR] BroadcastOutputTest.testBroadcastWithChain » JobExecution Job execution failed... 2022-05-19T10:17:34.6776205Z [ERROR] BroadcastOutputTest.testBroadcastWithMixedOutputWithSideOutput » JobExecution ... 2022-05-19T10:17:34.6776923Z [ERROR] BroadcastOutputTest.testBroadcastWithMixedOutputWithSideOutput » JobExecution ... 2022-05-19T10:17:34.6777577Z [ERROR] BroadcastOutputTest.testBroadcastWithMixedOutput » JobExecution Job execution ... 2022-05-19T10:17:34.6778199Z [ERROR] BroadcastOutputTest.testBroadcastWithMixedOutput » JobExecution Job execution ... 2022-05-19T10:17:34.6778808Z [ERROR] BroadcastOutputTest.testBroadcastWithMultipleChain » JobExecution Job executio... 2022-05-19T10:17:34.6779439Z [ERROR] BroadcastOutputTest.testBroadcastWithMultipleChain » JobExecution Job executio... 2022-05-19T10:17:34.6780096Z [ERROR] BroadcastOutputTest.testBroadcastWithMultipleResultPartitions » JobExecution J... 2022-05-19T10:17:34.6780774Z [ERROR] BroadcastOutputTest.testBroadcastWithMultipleResultPartitions » JobExecution J... 2022-05-19T10:17:34.6781420Z [ERROR] BroadcastOutputTest.testBroadcastWithResultPartition » JobExecution Job execut... 2022-05-19T10:17:34.6782061Z [ERROR] BroadcastOutputTest.testBroadcastWithResultPartition » JobExecution Job execut...
https://github.com/apache/flink-ml/runs/6505261269?check_suite_focus=true