You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/08/25 03:14:00 UTC
[jira] [Created] (FLINK-29102) ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError
Xingbo Huang created FLINK-29102:
------------------------------------
Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError
Key: FLINK-29102
URL: https://issues.apache.org/jira/browse/FLINK-29102
Project: Flink
Issue Type: Bug
Components: Runtime / State Backends
Affects Versions: 1.16.0
Reporter: Xingbo Huang
Fix For: 1.16.0
{code:java}
2022-08-25T02:10:19.1407131Z Aug 25 02:10:19 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 20.126 s <<< FAILURE! - in org.apache.flink.test.checkpointing.ChangelogLocalRecoveryITCase
2022-08-25T02:10:19.1410088Z Aug 25 02:10:19 [ERROR] ChangelogLocalRecoveryITCase.testRestartTM Time elapsed: 12.501 s <<< FAILURE!
2022-08-25T02:10:19.1411734Z Aug 25 02:10:19 org.opentest4j.AssertionFailedError: Graph is in globally terminal state (FAILED)
2022-08-25T02:10:19.1413028Z Aug 25 02:10:19 at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:43)
2022-08-25T02:10:19.1414753Z Aug 25 02:10:19 at org.junit.jupiter.api.Assertions.fail(Assertions.java:146)
2022-08-25T02:10:19.1416077Z Aug 25 02:10:19 at org.apache.flink.runtime.testutils.CommonTestUtils.lambda$waitForAllTaskRunning$3(CommonTestUtils.java:213)
2022-08-25T02:10:19.1417807Z Aug 25 02:10:19 at org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:150)
2022-08-25T02:10:19.1419455Z Aug 25 02:10:19 at org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:144)
2022-08-25T02:10:19.1421184Z Aug 25 02:10:19 at org.apache.flink.runtime.testutils.CommonTestUtils.waitForAllTaskRunning(CommonTestUtils.java:208)
2022-08-25T02:10:19.1422893Z Aug 25 02:10:19 at org.apache.flink.test.checkpointing.ChangelogLocalRecoveryITCase.testRestartTM(ChangelogLocalRecoveryITCase.java:149)
2022-08-25T02:10:19.1424381Z Aug 25 02:10:19 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-08-25T02:10:19.1425730Z Aug 25 02:10:19 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-08-25T02:10:19.1427428Z Aug 25 02:10:19 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-08-25T02:10:19.1428842Z Aug 25 02:10:19 at java.lang.reflect.Method.invoke(Method.java:498)
2022-08-25T02:10:19.1430173Z Aug 25 02:10:19 at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-08-25T02:10:19.1431683Z Aug 25 02:10:19 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-08-25T02:10:19.1433150Z Aug 25 02:10:19 at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-08-25T02:10:19.1434760Z Aug 25 02:10:19 at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-08-25T02:10:19.1436296Z Aug 25 02:10:19 at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2022-08-25T02:10:19.1437704Z Aug 25 02:10:19 at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2022-08-25T02:10:19.1439268Z Aug 25 02:10:19 at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2022-08-25T02:10:19.1441412Z Aug 25 02:10:19 at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2022-08-25T02:10:19.1442792Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-08-25T02:10:19.1444190Z Aug 25 02:10:19 at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2022-08-25T02:10:19.1445593Z Aug 25 02:10:19 at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2022-08-25T02:10:19.1446946Z Aug 25 02:10:19 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2022-08-25T02:10:19.1448568Z Aug 25 02:10:19 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2022-08-25T02:10:19.1449909Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-08-25T02:10:19.1451376Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-08-25T02:10:19.1452655Z Aug 25 02:10:19 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-08-25T02:10:19.1454003Z Aug 25 02:10:19 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-08-25T02:10:19.1455239Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-08-25T02:10:19.1456511Z Aug 25 02:10:19 at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-08-25T02:10:19.1458149Z Aug 25 02:10:19 at org.junit.runners.Suite.runChild(Suite.java:128)
2022-08-25T02:10:19.1460189Z Aug 25 02:10:19 at org.junit.runners.Suite.runChild(Suite.java:27)
2022-08-25T02:10:19.1461574Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-08-25T02:10:19.1462877Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-08-25T02:10:19.1464471Z Aug 25 02:10:19 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-08-25T02:10:19.1465869Z Aug 25 02:10:19 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-08-25T02:10:19.1467177Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-08-25T02:10:19.1468801Z Aug 25 02:10:19 at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2022-08-25T02:10:19.1470145Z Aug 25 02:10:19 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
2022-08-25T02:10:19.1471536Z Aug 25 02:10:19 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2022-08-25T02:10:19.1472951Z Aug 25 02:10:19 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-08-25T02:10:19.1474218Z Aug 25 02:10:19 at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-08-25T02:10:19.1475390Z Aug 25 02:10:19 at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
2022-08-25T02:10:19.1476566Z Aug 25 02:10:19 at org.junit.runner.JUnitCore.run(JUnitCore.java:115)
2022-08-25T02:10:19.1478077Z Aug 25 02:10:19 at org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
2022-08-25T02:10:19.1480014Z Aug 25 02:10:19 at org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
2022-08-25T02:10:19.1481463Z Aug 25 02:10:19 at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
2022-08-25T02:10:19.1482776Z Aug 25 02:10:19 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2022-08-25T02:10:19.1486583Z Aug 25 02:10:19 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2022-08-25T02:10:19.1488264Z Aug 25 02:10:19 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2022-08-25T02:10:19.1489877Z Aug 25 02:10:19 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2022-08-25T02:10:19.1491691Z Aug 25 02:10:19 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2022-08-25T02:10:19.1492986Z Aug 25 02:10:19 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2022-08-25T02:10:19.1494236Z Aug 25 02:10:19 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2022-08-25T02:10:19.1495567Z Aug 25 02:10:19 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2022-08-25T02:10:19.1496961Z Aug 25 02:10:19 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2022-08-25T02:10:19.1498390Z Aug 25 02:10:19 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2022-08-25T02:10:19.1499796Z Aug 25 02:10:19 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2022-08-25T02:10:19.1501267Z Aug 25 02:10:19 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
2022-08-25T02:10:19.1502560Z Aug 25 02:10:19 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2022-08-25T02:10:19.1503777Z Aug 25 02:10:19 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2022-08-25T02:10:19.1504924Z Aug 25 02:10:19 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2022-08-25T02:10:19.1506127Z Aug 25 02:10:19 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-08-25T02:10:19.1507702Z Aug 25 02:10:19 Caused by: org.apache.flink.runtime.JobException: org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1, backoffTimeMS=10)
2022-08-25T02:10:19.1509606Z Aug 25 02:10:19 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:139)
2022-08-25T02:10:19.1511280Z Aug 25 02:10:19 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:83)
2022-08-25T02:10:19.1512791Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:256)
2022-08-25T02:10:19.1514116Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247)
2022-08-25T02:10:19.1515412Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240)
2022-08-25T02:10:19.1516738Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:738)
2022-08-25T02:10:19.1518192Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:715)
2022-08-25T02:10:19.1519748Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
2022-08-25T02:10:19.1521544Z Aug 25 02:10:19 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1619)
2022-08-25T02:10:19.1522964Z Aug 25 02:10:19 at org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1137)
2022-08-25T02:10:19.1524151Z Aug 25 02:10:19 at org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1077)
2022-08-25T02:10:19.1525332Z Aug 25 02:10:19 at org.apache.flink.runtime.executiongraph.Execution.fail(Execution.java:778)
2022-08-25T02:10:19.1526624Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.signalPayloadRelease(SingleLogicalSlot.java:195)
2022-08-25T02:10:19.1528105Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.release(SingleLogicalSlot.java:182)
2022-08-25T02:10:19.1529562Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.SharedSlot.lambda$release$4(SharedSlot.java:270)
2022-08-25T02:10:19.1530816Z Aug 25 02:10:19 at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
2022-08-25T02:10:19.1531900Z Aug 25 02:10:19 at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683)
2022-08-25T02:10:19.1532921Z Aug 25 02:10:19 at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010)
2022-08-25T02:10:19.1533628Z Aug 25 02:10:19 at org.apache.flink.runtime.scheduler.SharedSlot.release(SharedSlot.java:270)
2022-08-25T02:10:19.1534360Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot.releasePayload(AllocatedSlot.java:152)
2022-08-25T02:10:19.1535210Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releasePayload(DefaultDeclarativeSlotPool.java:483)
2022-08-25T02:10:19.1536322Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.freeAndReleaseSlots(DefaultDeclarativeSlotPool.java:475)
2022-08-25T02:10:19.1537411Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releaseSlots(DefaultDeclarativeSlotPool.java:446)
2022-08-25T02:10:19.1538422Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.internalReleaseTaskManager(DeclarativeSlotPoolService.java:275)
2022-08-25T02:10:19.1539375Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.releaseTaskManager(DeclarativeSlotPoolService.java:231)
2022-08-25T02:10:19.1540193Z Aug 25 02:10:19 at org.apache.flink.runtime.jobmaster.JobMaster.disconnectTaskManager(JobMaster.java:533)
2022-08-25T02:10:19.1540913Z Aug 25 02:10:19 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-08-25T02:10:19.1541778Z Aug 25 02:10:19 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-08-25T02:10:19.1542700Z Aug 25 02:10:19 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-08-25T02:10:19.1543354Z Aug 25 02:10:19 at java.lang.reflect.Method.invoke(Method.java:498)
2022-08-25T02:10:19.1544039Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309)
2022-08-25T02:10:19.1544853Z Aug 25 02:10:19 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-08-25T02:10:19.1545661Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307)
2022-08-25T02:10:19.1546413Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
2022-08-25T02:10:19.1547179Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
2022-08-25T02:10:19.1548110Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
2022-08-25T02:10:19.1548869Z Aug 25 02:10:19 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-08-25T02:10:19.1549682Z Aug 25 02:10:19 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-08-25T02:10:19.1550579Z Aug 25 02:10:19 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-08-25T02:10:19.1551529Z Aug 25 02:10:19 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-08-25T02:10:19.1552170Z Aug 25 02:10:19 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-08-25T02:10:19.1552821Z Aug 25 02:10:19 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-08-25T02:10:19.1553467Z Aug 25 02:10:19 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-08-25T02:10:19.1554125Z Aug 25 02:10:19 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-08-25T02:10:19.1554732Z Aug 25 02:10:19 at akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-08-25T02:10:19.1555398Z Aug 25 02:10:19 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-08-25T02:10:19.1555993Z Aug 25 02:10:19 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-08-25T02:10:19.1556612Z Aug 25 02:10:19 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-08-25T02:10:19.1557203Z Aug 25 02:10:19 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-08-25T02:10:19.1557942Z Aug 25 02:10:19 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-08-25T02:10:19.1558512Z Aug 25 02:10:19 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-08-25T02:10:19.1559032Z Aug 25 02:10:19 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-08-25T02:10:19.1559620Z Aug 25 02:10:19 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-08-25T02:10:19.1560282Z Aug 25 02:10:19 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-08-25T02:10:19.1561023Z Aug 25 02:10:19 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-08-25T02:10:19.1561690Z Aug 25 02:10:19 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-08-25T02:10:19.1562440Z Aug 25 02:10:19 Caused by: org.apache.flink.util.FlinkExpectedException: org.apache.flink.util.FlinkExpectedException: The TaskExecutor is shutting down.
2022-08-25T02:10:19.1563197Z Aug 25 02:10:19 at org.apache.flink.runtime.taskexecutor.TaskExecutor.onStop(TaskExecutor.java:456)
2022-08-25T02:10:19.1563908Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:238)
2022-08-25T02:10:19.1564671Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.lambda$terminate$0(AkkaRpcActor.java:578)
2022-08-25T02:10:19.1565497Z Aug 25 02:10:19 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-08-25T02:10:19.1566406Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:577)
2022-08-25T02:10:19.1567177Z Aug 25 02:10:19 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:196)
2022-08-25T02:10:19.1568114Z Aug 25 02:10:19 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-08-25T02:10:19.1568721Z Aug 25 02:10:19 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-08-25T02:10:19.1569337Z Aug 25 02:10:19 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-08-25T02:10:19.1569944Z Aug 25 02:10:19 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-08-25T02:10:19.1570568Z Aug 25 02:10:19 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-08-25T02:10:19.1571302Z Aug 25 02:10:19 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-08-25T02:10:19.1571808Z Aug 25 02:10:19 ... 13 more {code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40355&view=logs&j=baf26b34-3c6a-54e8-f93f-cf269b32f802&t=8c9d126d-57d2-5a9e-a8c8-ff53f7b35cd9
--
This message was sent by Atlassian Jira
(v8.20.10#820010)