Zhipeng Zhang created FLINK-26801:
-------------------------------------
Summary: LogisticRegressionTest.testGetModelData» Runtime Failed
to fetch next res...
Key: FLINK-26801
URL: https://issues.apache.org/jira/browse/FLINK-26801
Project: Flink
Issue Type: Bug
Components: Library / Machine Learning
Affects Versions: ml-2.0.0
Reporter: Zhipeng Zhang
The flink-ml run fails at the following case [1]:
```
Error: Tests run: 8, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 71.967
s <<< FAILURE! - in org.apache.flink.ml.classification.LogisticRegressionTest
[27997|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:27997]Error:
testGetModelData Time elapsed: 3.221 s <<< ERROR!
[27998|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:27998]java.lang.RuntimeException:
Failed to fetch next result
[27999|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:27999]
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
[28000|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28000]
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.next(CollectResultIterator.java:88)
[28001|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28001]
at
org.apache.flink.ml.classification.LogisticRegressionTest.testGetModelData(LogisticRegressionTest.java:251)
[28002|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28002]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
[28003|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28003]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
[28004|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28004]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
[28005|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28005]
at java.lang.reflect.Method.invoke(Method.java:498)
[28006|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28006]
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
[28007|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28007]
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
[28008|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28008]
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
[28009|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28009]
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
[28010|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28010]
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
[28011|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28011]
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
[28012|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28012]
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
[28013|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28013]
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
[28014|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28014]
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
[28015|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28015]
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
[28016|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28016]
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
[28017|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28017]
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
[28018|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28018]
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
[28019|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28019]
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
[28020|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28020]
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
[28021|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28021]
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
[28022|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28022]
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
[28023|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28023]
at org.junit.runner.JUnitCore.run(JUnitCore.java:115)
[28024|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28024]
at
org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43)
[28025|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28025]
at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
[28026|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28026]
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
[28027|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28027]
at java.util.Iterator.forEachRemaining(Iterator.java:116)
[28028|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28028]
at
java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
[28029|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28029]
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
[28030|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28030]
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
[28031|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28031]
at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
[28032|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28032]
at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
[28033|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28033]
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
[28034|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28034]
at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
[28035|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28035]
at
org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:82)
[28036|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28036]
at
org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:73)
[28037|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28037]
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:220)
[28038|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28038]
at
org.junit.platform.launcher.core.DefaultLauncher.lambda$execute$6(DefaultLauncher.java:188)
[28039|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28039]
at
org.junit.platform.launcher.core.DefaultLauncher.withInterceptedStreams(DefaultLauncher.java:202)
[28040|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28040]
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:181)
[28041|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28041]
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:128)
[28042|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28042]
at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:142)
[28043|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28043]
at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:109)
[28044|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28044]
at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
[28045|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28045]
at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
[28046|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28046]
at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
[28047|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28047]
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
[28048|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28048]Caused
by: java.io.IOException: Failed to fetch job execution result
[28049|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28049]
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:177)
[28050|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28050]
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:120)
[28051|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28051]
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
[28052|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28052]
... 48 more
[28053|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28053]Caused
by: java.util.concurrent.ExecutionException:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
[28054|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28054]
at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
[28055|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28055]
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
[28056|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28056]
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:175)
[28057|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28057]
... 50 more
[28058|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28058]Caused
by: org.apache.flink.runtime.client.JobExecutionException: Job execution
failed.
[28059|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28059]
at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
[28060|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28060]
at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
[28061|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28061]
at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
[28062|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28062]
at
java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628)
[28063|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28063]
at
java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996)
[28064|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28064]
at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:134)
[28065|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28065]
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:174)
[28066|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28066]
... 50 more
[28067|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28067]Caused
by: org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
[28068|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28068]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
[28069|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28069]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
[28070|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28070]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:228)
[28071|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28071]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:218)
[28072|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28072]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:209)
[28073|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28073]
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:679)
[28074|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28074]
at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
[28075|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28075]
at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444)
[28076|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28076]
at sun.reflect.GeneratedMethodAccessor18.invoke(Unknown Source)
[28077|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28077]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
[28078|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28078]
at java.lang.reflect.Method.invoke(Method.java:498)
[28079|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28079]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316)
[28080|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28080]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
[28081|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28081]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314)
[28082|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28082]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
[28083|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28083]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
[28084|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28084]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
[28085|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28085]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
[28086|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28086]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
[28087|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28087]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
[28088|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28088]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
[28089|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28089]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
[28090|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28090]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
[28091|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28091]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[28092|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28092]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[28093|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28093]
at akka.actor.Actor.aroundReceive(Actor.scala:537)
[28094|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28094]
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
[28095|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28095]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
[28096|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28096]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
[28097|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28097]
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
[28098|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28098]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
[28099|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28099]
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
[28100|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28100]
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
[28101|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28101]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[28102|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28102]
at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[28103|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28103]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[28104|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28104]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[28105|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28105]Caused
by: java.lang.IllegalStateException: Should be blocked by checkpoint.
[28106|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28106]
at org.apache.flink.util.Preconditions.checkState(Preconditions.java:193)
[28107|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28107]
at
org.apache.flink.runtime.io.network.partition.PipelinedSubpartition.resumeConsumption(PipelinedSubpartition.java:381)
[28108|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28108]
at
org.apache.flink.runtime.io.network.partition.PipelinedSubpartitionView.resumeConsumption(PipelinedSubpartitionView.java:79)
[28109|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28109]
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.resumeConsumption(LocalInputChannel.java:283)
[28110|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28110]
at
org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.resumeConsumption(SingleInputGate.java:867)
[28111|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28111]
at
org.apache.flink.runtime.taskmanager.InputGateWithMetrics.resumeConsumption(InputGateWithMetrics.java:67)
[28112|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28112]
at
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.processBarrier(SingleCheckpointBarrierHandler.java:223)
[28113|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28113]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerUnfinishedChannelsCheckpoint(StreamTask.java:1209)
[28114|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28114]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$triggerCheckpointAsync$12(StreamTask.java:1126)
[28115|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28115]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
[28116|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28116]
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
[28117|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28117]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.yield(MailboxExecutorImpl.java:86)
[28118|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28118]
at
org.apache.flink.iteration.operator.HeadOperator.endInput(HeadOperator.java:408)
[28119|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28119]
at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.endOperatorInput(StreamOperatorWrapper.java:91)
[28120|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28120]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.endInput(RegularOperatorChain.java:100)
[28121|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28121]
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:68)
[28122|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28122]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)
[28123|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28123]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
[28124|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28124]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)
[28125|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28125]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)
[28126|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28126]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
[28127|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28127]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
[28128|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28128]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
[28129|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28129]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
[28130|https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true#step:4:28130]
at java.lang.Thread.run(Thread.java:750)
```
[1]https://github.com/apache/flink-ml/runs/5638224415?check_suite_focus=true
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
