Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Duplicate
-
1.15.0
Description
The AZP build for fine grained resource management failed with exit code 137, when running an extensive list of checkpointing tests:
2021-12-21T06:06:08.8728404Z Dec 21 06:06:08 [INFO] Running org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase 2021-12-21T06:06:37.6584668Z Dec 21 06:06:37 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale union from 3 to 7, buffersPerChannel = 0]. 2021-12-21T06:06:37.6585685Z Dec 21 06:06:37 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale union from 3 to 7, buffersPerChannel = 0]. 2021-12-21T06:06:37.6593448Z Dec 21 06:06:37 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale union from 3 to 7, buffersPerChannel = 0]. 2021-12-21T06:06:41.3044200Z Dec 21 06:06:41 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:06:41.3045146Z Dec 21 06:06:41 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:06:49.7482529Z Dec 21 06:06:49 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:06:49.7483922Z Dec 21 06:06:49 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:06:56.7462828Z Dec 21 06:06:56 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:06:56.7463831Z Dec 21 06:06:56 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:07:06.7225398Z Dec 21 06:07:06 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:07:06.7226580Z Dec 21 06:07:06 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:07:12.1987555Z Dec 21 06:07:12 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale union from 3 to 7, buffersPerChannel = 1]. 2021-12-21T06:07:12.1992168Z Dec 21 06:07:12 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale union from 3 to 7, buffersPerChannel = 1]. 2021-12-21T06:07:12.1993591Z Dec 21 06:07:12 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale union from 3 to 7, buffersPerChannel = 1]. 2021-12-21T06:07:16.3825669Z Dec 21 06:07:15 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:07:16.3826827Z Dec 21 06:07:15 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:07:23.4489701Z Dec 21 06:07:23 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:07:23.4495250Z Dec 21 06:07:23 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 0]. 2021-12-21T06:07:29.8407484Z Dec 21 06:07:29 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:29.8417385Z Dec 21 06:07:29 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:31.2376012Z Dec 21 06:07:31 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 2 to 1, buffersPerChannel = 0]. 2021-12-21T06:07:31.2382722Z Dec 21 06:07:31 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 2 to 1, buffersPerChannel = 0]. 2021-12-21T06:07:31.2387732Z Dec 21 06:07:31 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 2 to 1, buffersPerChannel = 0]. 2021-12-21T06:07:35.4068535Z Dec 21 06:07:35 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:35.4104210Z Dec 21 06:07:35 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:41.8835831Z Dec 21 06:07:41 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:41.8850176Z Dec 21 06:07:41 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:43.4534043Z Dec 21 06:07:43 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 2 to 1, buffersPerChannel = 1]. 2021-12-21T06:07:43.4566611Z Dec 21 06:07:43 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 2 to 1, buffersPerChannel = 1]. 2021-12-21T06:07:43.4570536Z Dec 21 06:07:43 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 2 to 1, buffersPerChannel = 1]. 2021-12-21T06:07:48.8854031Z Dec 21 06:07:48 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:48.8858894Z Dec 21 06:07:48 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:54.2639437Z Dec 21 06:07:54 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:54.2649928Z Dec 21 06:07:54 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:07:57.0921700Z Dec 21 06:07:57 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 3 to 2, buffersPerChannel = 0]. 2021-12-21T06:07:57.0930134Z Dec 21 06:07:57 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 3 to 2, buffersPerChannel = 0]. 2021-12-21T06:07:57.0937347Z Dec 21 06:07:57 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 3 to 2, buffersPerChannel = 0]. 2021-12-21T06:08:00.4006969Z Dec 21 06:08:00 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:08:00.4017900Z Dec 21 06:08:00 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =MEM, buffersPerChannel = 2]. 2021-12-21T06:08:12.1410498Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 2021-12-21T06:08:12.1415409Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 2021-12-21T06:08:12.1416272Z at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 2021-12-21T06:08:12.1417854Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 2021-12-21T06:08:12.1428251Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 2021-12-21T06:08:12.1434755Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2021-12-21T06:08:12.1435731Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2021-12-21T06:08:12.1597764Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) 2021-12-21T06:08:12.1605280Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2021-12-21T06:08:12.1617993Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2021-12-21T06:08:12.1624766Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2021-12-21T06:08:12.1628608Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2021-12-21T06:08:12.1633487Z at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) 2021-12-21T06:08:12.1636953Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) 2021-12-21T06:08:12.1641835Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) 2021-12-21T06:08:12.1645859Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) 2021-12-21T06:08:12.1649336Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 2021-12-21T06:08:12.1650090Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 2021-12-21T06:08:12.1651243Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 2021-12-21T06:08:12.1655861Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 2021-12-21T06:08:12.1656895Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) 2021-12-21T06:08:12.1661986Z at akka.dispatch.OnComplete.internal(Future.scala:300) 2021-12-21T06:08:12.1662576Z at akka.dispatch.OnComplete.internal(Future.scala:297) 2021-12-21T06:08:12.1663437Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) 2021-12-21T06:08:12.1664213Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) 2021-12-21T06:08:12.1664869Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2021-12-21T06:08:12.1670608Z at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) 2021-12-21T06:08:12.1671491Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) 2021-12-21T06:08:12.1672703Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) 2021-12-21T06:08:12.1673473Z at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) 2021-12-21T06:08:12.1678327Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) 2021-12-21T06:08:12.1679245Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) 2021-12-21T06:08:12.1679919Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) 2021-12-21T06:08:12.1680642Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) 2021-12-21T06:08:12.1681284Z at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) 2021-12-21T06:08:12.1686459Z at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) 2021-12-21T06:08:12.1687299Z at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) 2021-12-21T06:08:12.1688250Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) 2021-12-21T06:08:12.1689135Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) 2021-12-21T06:08:12.1690169Z at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) 2021-12-21T06:08:12.1695578Z at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) 2021-12-21T06:08:12.1696237Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) 2021-12-21T06:08:12.1697027Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) 2021-12-21T06:08:12.1697753Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) 2021-12-21T06:08:12.1702217Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) 2021-12-21T06:08:12.1703523Z at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 2021-12-21T06:08:12.1704260Z at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 2021-12-21T06:08:12.1705010Z at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 2021-12-21T06:08:12.1705582Z at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 2021-12-21T06:08:12.1710510Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1, backoffTimeMS=0) 2021-12-21T06:08:12.1711429Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) 2021-12-21T06:08:12.1712468Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) 2021-12-21T06:08:12.1713557Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) 2021-12-21T06:08:12.1718442Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) 2021-12-21T06:08:12.1719496Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) 2021-12-21T06:08:12.1720212Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:696) 2021-12-21T06:08:12.1721098Z at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) 2021-12-21T06:08:12.1721774Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:445) 2021-12-21T06:08:12.1726562Z at sun.reflect.GeneratedMethodAccessor13.invoke(Unknown Source) 2021-12-21T06:08:12.1727387Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2021-12-21T06:08:12.1728007Z at java.lang.reflect.Method.invoke(Method.java:498) 2021-12-21T06:08:12.1728636Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) 2021-12-21T06:08:12.1729709Z at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) 2021-12-21T06:08:12.1734890Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) 2021-12-21T06:08:12.1735620Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) 2021-12-21T06:08:12.1736333Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) 2021-12-21T06:08:12.1737197Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) 2021-12-21T06:08:12.1742688Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) 2021-12-21T06:08:12.1743341Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) 2021-12-21T06:08:12.1744018Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) 2021-12-21T06:08:12.1744572Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) 2021-12-21T06:08:12.1745157Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) 2021-12-21T06:08:12.1750660Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) 2021-12-21T06:08:12.1751300Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2021-12-21T06:08:12.1751892Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) 2021-12-21T06:08:12.1752445Z at akka.actor.Actor.aroundReceive(Actor.scala:537) 2021-12-21T06:08:12.1753074Z at akka.actor.Actor.aroundReceive$(Actor.scala:535) 2021-12-21T06:08:12.1758203Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) 2021-12-21T06:08:12.1758926Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) 2021-12-21T06:08:12.1759473Z at akka.actor.ActorCell.invoke(ActorCell.scala:548) 2021-12-21T06:08:12.1760015Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) 2021-12-21T06:08:12.1764801Z at akka.dispatch.Mailbox.run(Mailbox.scala:231) 2021-12-21T06:08:12.1765570Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243) 2021-12-21T06:08:12.1765954Z ... 4 more 2021-12-21T06:08:12.1766547Z Caused by: java.lang.Exception: Exception while creating StreamOperatorStateContext. 2021-12-21T06:08:12.1767317Z at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:255) 2021-12-21T06:08:12.1772588Z at org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:268) 2021-12-21T06:08:12.1773465Z at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:110) 2021-12-21T06:08:12.1774335Z at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:697) 2021-12-21T06:08:12.1775070Z at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55) 2021-12-21T06:08:12.1775769Z at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:673) 2021-12-21T06:08:12.1780965Z at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:640) 2021-12-21T06:08:12.1781675Z at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) 2021-12-21T06:08:12.1782463Z at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917) 2021-12-21T06:08:12.1783093Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) 2021-12-21T06:08:12.1787626Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) 2021-12-21T06:08:12.1788244Z at java.lang.Thread.run(Thread.java:748) 2021-12-21T06:08:12.1788922Z Caused by: org.apache.flink.util.FlinkException: Could not restore keyed state backend for WindowOperator_0a448493b4782967b150582570326227_(1/4) from any of the 1 provided restore options. 2021-12-21T06:08:12.1789829Z at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:160) 2021-12-21T06:08:12.1790696Z at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.keyedStatedBackend(StreamTaskStateInitializerImpl.java:346) 2021-12-21T06:08:12.1796225Z at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:164) 2021-12-21T06:08:12.1796880Z ... 11 more 2021-12-21T06:08:12.1929572Z Caused by: java.lang.RuntimeException: java.io.FileNotFoundException: /tmp/junit1602319139396542693/junit2304571881994301673/dd79b29a-682f-4a25-bca7-9e43cef5e1d1 (No such file or directory) 2021-12-21T06:08:12.1930651Z at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:319) 2021-12-21T06:08:12.1935588Z at org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.advance(StateChangelogHandleStreamHandleReader.java:87) 2021-12-21T06:08:12.1938897Z at org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.hasNext(StateChangelogHandleStreamHandleReader.java:69) 2021-12-21T06:08:12.1944207Z at org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.readBackendHandle(ChangelogBackendRestoreOperation.java:92) 2021-12-21T06:08:12.1945156Z at org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.restore(ChangelogBackendRestoreOperation.java:74) 2021-12-21T06:08:12.1950132Z at org.apache.flink.state.changelog.ChangelogStateBackend.restore(ChangelogStateBackend.java:221) 2021-12-21T06:08:12.1951349Z at org.apache.flink.state.changelog.ChangelogStateBackend.createKeyedStateBackend(ChangelogStateBackend.java:145) 2021-12-21T06:08:12.1952172Z at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.lambda$keyedStatedBackend$1(StreamTaskStateInitializerImpl.java:329) 2021-12-21T06:08:12.1953295Z at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.attemptCreateAndRestore(BackendRestorerProcedure.java:168) 2021-12-21T06:08:12.1954441Z at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:135) 2021-12-21T06:08:12.1960137Z ... 13 more 2021-12-21T06:08:12.1961315Z Caused by: java.io.FileNotFoundException: /tmp/junit1602319139396542693/junit2304571881994301673/dd79b29a-682f-4a25-bca7-9e43cef5e1d1 (No such file or directory) 2021-12-21T06:08:12.1962007Z at java.io.FileInputStream.open0(Native Method) 2021-12-21T06:08:12.1962665Z at java.io.FileInputStream.open(FileInputStream.java:195) 2021-12-21T06:08:12.1967137Z at java.io.FileInputStream.<init>(FileInputStream.java:138) 2021-12-21T06:08:12.1967995Z at org.apache.flink.core.fs.local.LocalDataInputStream.<init>(LocalDataInputStream.java:50) 2021-12-21T06:08:12.1968661Z at org.apache.flink.core.fs.local.LocalFileSystem.open(LocalFileSystem.java:134) 2021-12-21T06:08:12.1969318Z at org.apache.flink.core.fs.SafetyNetWrapperFileSystem.open(SafetyNetWrapperFileSystem.java:87) 2021-12-21T06:08:12.1970019Z at org.apache.flink.runtime.state.filesystem.FileStateHandle.openInputStream(FileStateHandle.java:68) 2021-12-21T06:08:12.1976459Z Dec 21 06:08:12 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:12.1977524Z Dec 21 06:08:12 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:12.1978346Z at org.apache.flink.changelog.fs.StateChangeFormat.read(StateChangeFormat.java:92) 2021-12-21T06:08:12.1979239Z at org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.advance(StateChangelogHandleStreamHandleReader.java:85) 2021-12-21T06:08:12.1982680Z ... 21 more 2021-12-21T06:08:15.8131284Z Dec 21 06:08:15 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 3 to 2, buffersPerChannel = 1]. 2021-12-21T06:08:15.8132921Z Dec 21 06:08:15 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 3 to 2, buffersPerChannel = 1]. 2021-12-21T06:08:15.8134329Z Dec 21 06:08:15 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 3 to 2, buffersPerChannel = 1]. 2021-12-21T06:08:18.5902129Z Dec 21 06:08:18 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:18.5926512Z Dec 21 06:08:18 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:27.4704772Z Dec 21 06:08:27 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:27.4705814Z Dec 21 06:08:27 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:34.4616437Z Dec 21 06:08:34 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:34.4631814Z Dec 21 06:08:34 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:37.4353476Z Dec 21 06:08:37 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 7 to 3, buffersPerChannel = 0]. 2021-12-21T06:08:37.4358241Z Dec 21 06:08:37 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 7 to 3, buffersPerChannel = 0]. 2021-12-21T06:08:37.4362799Z Dec 21 06:08:37 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 7 to 3, buffersPerChannel = 0]. 2021-12-21T06:08:41.4421350Z Dec 21 06:08:41 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:41.4422769Z Dec 21 06:08:41 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:49.8087106Z Dec 21 06:08:49 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:49.8091055Z Dec 21 06:08:49 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 0]. 2021-12-21T06:08:56.3765029Z Dec 21 06:08:56 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:08:56.3766170Z Dec 21 06:08:56 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:08:58.9072907Z Dec 21 06:08:58 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 7 to 3, buffersPerChannel = 1]. 2021-12-21T06:08:58.9079161Z Dec 21 06:08:58 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 7 to 3, buffersPerChannel = 1]. 2021-12-21T06:08:58.9085274Z Dec 21 06:08:58 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[downscale union from 7 to 3, buffersPerChannel = 1]. 2021-12-21T06:09:02.5717900Z Dec 21 06:09:02 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:02.5724454Z Dec 21 06:09:02 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:08.3095467Z Dec 21 06:09:08 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:08.3096598Z Dec 21 06:09:08 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:10.4300059Z Dec 21 06:09:10 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 1 to 1, buffersPerChannel = 0]. 2021-12-21T06:09:10.4309488Z Dec 21 06:09:10 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 1 to 1, buffersPerChannel = 0]. 2021-12-21T06:09:10.4315846Z Dec 21 06:09:10 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 1 to 1, buffersPerChannel = 0]. 2021-12-21T06:09:14.4353046Z Dec 21 06:09:14 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:14.4358399Z Dec 21 06:09:14 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:19.8779097Z Dec 21 06:09:19 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:19.8785621Z Dec 21 06:09:19 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:21.4836766Z Dec 21 06:09:21 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 1 to 1, buffersPerChannel = 1]. 2021-12-21T06:09:21.4840441Z Dec 21 06:09:21 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 1 to 1, buffersPerChannel = 1]. 2021-12-21T06:09:21.4844309Z Dec 21 06:09:21 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 1 to 1, buffersPerChannel = 1]. 2021-12-21T06:09:26.1985322Z Dec 21 06:09:26 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:26.1998219Z Dec 21 06:09:26 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =FILE, buffersPerChannel = 2]. 2021-12-21T06:09:50.4088289Z Dec 21 06:09:50 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:09:50.4096473Z Dec 21 06:09:50 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:09:58.0775962Z Dec 21 06:09:58 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:09:58.0777522Z Dec 21 06:09:58 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:05.5467071Z Dec 21 06:10:05 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:05.5474709Z Dec 21 06:10:05 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:17.4955728Z Dec 21 06:10:17 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:17.4969255Z Dec 21 06:10:17 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:24.4758454Z Dec 21 06:10:24 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 7 to 7, buffersPerChannel = 0]. 2021-12-21T06:10:24.4772548Z Dec 21 06:10:24 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 7 to 7, buffersPerChannel = 0]. 2021-12-21T06:10:24.4773746Z Dec 21 06:10:24 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 7 to 7, buffersPerChannel = 0]. 2021-12-21T06:10:28.5247207Z Dec 21 06:10:28 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:28.5255460Z Dec 21 06:10:28 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:59.3126158Z Dec 21 06:10:59 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:10:59.3131182Z Dec 21 06:10:59 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 0]. 2021-12-21T06:11:07.5597066Z Dec 21 06:11:07 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 7 to 7, buffersPerChannel = 1]. 2021-12-21T06:11:07.5603856Z Dec 21 06:11:07 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 7 to 7, buffersPerChannel = 1]. 2021-12-21T06:11:07.5609023Z Dec 21 06:11:07 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[no scale union from 7 to 7, buffersPerChannel = 1]. 2021-12-21T06:11:27.2695728Z Dec 21 06:11:27 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:11:27.2700158Z Dec 21 06:11:27 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testSlidingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:11:27.7464683Z Dec 21 06:11:27 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 1 to 2, buffersPerChannel = 0]. 2021-12-21T06:11:27.7467983Z Dec 21 06:11:27 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 1 to 2, buffersPerChannel = 0]. 2021-12-21T06:11:27.7468950Z Dec 21 06:11:27 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 1 to 2, buffersPerChannel = 0]. 2021-12-21T06:11:34.8076350Z Dec 21 06:11:34 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:11:34.8077569Z Dec 21 06:11:34 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMinMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:11:40.5262452Z Dec 21 06:11:40 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 1 to 2, buffersPerChannel = 1]. 2021-12-21T06:11:40.5366961Z Dec 21 06:11:40 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 1 to 2, buffersPerChannel = 1]. 2021-12-21T06:11:40.5370724Z Dec 21 06:11:40 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 1 to 2, buffersPerChannel = 1]. 2021-12-21T06:11:57.4279555Z Dec 21 06:11:57 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:11:57.4290116Z Dec 21 06:11:57 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:12:01.7009109Z Dec 21 06:12:01 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 2 to 3, buffersPerChannel = 0]. 2021-12-21T06:12:01.7010678Z Dec 21 06:12:01 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 2 to 3, buffersPerChannel = 0]. 2021-12-21T06:12:01.7021826Z Dec 21 06:12:01 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 2 to 3, buffersPerChannel = 0]. 2021-12-21T06:12:10.9736526Z Dec 21 06:12:10 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:12:10.9740685Z Dec 21 06:12:10 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:12:17.0251830Z Dec 21 06:12:16 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 2 to 3, buffersPerChannel = 1]. 2021-12-21T06:12:17.0265114Z Dec 21 06:12:16 Starting org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 2 to 3, buffersPerChannel = 1]. 2021-12-21T06:12:17.0271157Z Dec 21 06:12:16 Finished org.apache.flink.test.checkpointing.UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint[upscale multi_input from 2 to 3, buffersPerChannel = 1]. 2021-12-21T06:12:33.8727663Z Dec 21 06:12:33 Starting org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:12:33.8747903Z Dec 21 06:12:33 Finished org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase#testPreAggregatedTumblingTimeWindow[statebackend type =ROCKSDB_FULL, buffersPerChannel = 2]. 2021-12-21T06:13:10.5181732Z ##[error]Exit code 137 returned from process: file name '/usr/bin/docker', arguments 'exec -i -u 1001 -w /home/vsts_azpcontainer 7796bde44510825a871e84646b6e60d94c2c0ceb70380c294c1cb043c858368c /__a/externals/node/bin/node /__w/_temp/containerHandlerInvoker.js'. 2021-12-21T06:13:10.6200841Z ##[section]Finishing: Test - finegrained_resource_management
Attachments
Issue Links
- duplicates
-
FLINK-25395 FileNotFoundException during recovery caused by Incremental shared state being discarded by TM
- Resolved
- links to