Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25399

AZP fails with exit code 137 when running checkpointing test cases

    XMLWordPrintableJSON

Details

    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
      

      https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28403&view=logs&j=4d4a0d10-fca2-5507-8eed-c07f0bdf4887&t=7b25afdf-cc6c-566f-5459-359dc2585798

      Attachments

        Issue Links

          Activity

            People

              roman Roman Khachatryan
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: