Huang Xingbo created FLINK-27915:
------------------------------------
Summary: WindowJoinITCase.testInnerJoinOnWTFWithOffset failed with
InterruptedException
Key: FLINK-27915
URL: https://issues.apache.org/jira/browse/FLINK-27915
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.16.0
Reporter: Huang Xingbo
{code:java}
2022-06-04T03:55:42.6403835Z Jun 04 03:55:42 [ERROR] Tests run: 80, Failures:
0, Errors: 1, Skipped: 0, Time elapsed: 90.085 s <<< FAILURE! - in
org.apache.flink.table.planner.runtime.stream.sql.WindowJoinITCase
2022-06-04T03:55:42.6405383Z Jun 04 03:55:42 [ERROR]
WindowJoinITCase.testInnerJoinOnWTFWithOffset Time elapsed: 1.228 s <<< ERROR!
2022-06-04T03:55:42.6406676Z Jun 04 03:55:42
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-06-04T03:55:42.6407398Z Jun 04 03:55:42 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-06-04T03:55:42.6433580Z Jun 04 03:55:42 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
2022-06-04T03:55:42.6435011Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-06-04T03:55:42.6436197Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-06-04T03:55:42.6437458Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-04T03:55:42.6439108Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-04T03:55:42.6440559Z Jun 04 03:55:42 at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:268)
2022-06-04T03:55:42.6442232Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-06-04T03:55:42.6443814Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-06-04T03:55:42.6445174Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-04T03:55:42.6446427Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-04T03:55:42.6447547Z Jun 04 03:55:42 at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1277)
2022-06-04T03:55:42.6448854Z Jun 04 03:55:42 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
2022-06-04T03:55:42.6450237Z Jun 04 03:55:42 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-06-04T03:55:42.6451912Z Jun 04 03:55:42 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-06-04T03:55:42.6453755Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-06-04T03:55:42.6454979Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-06-04T03:55:42.6456447Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-04T03:55:42.6457742Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-04T03:55:42.6459136Z Jun 04 03:55:42 at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
2022-06-04T03:55:42.6460363Z Jun 04 03:55:42 at
akka.dispatch.OnComplete.internal(Future.scala:300)
2022-06-04T03:55:42.6461398Z Jun 04 03:55:42 at
akka.dispatch.OnComplete.internal(Future.scala:297)
2022-06-04T03:55:42.6462509Z Jun 04 03:55:42 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-06-04T03:55:42.6464606Z Jun 04 03:55:42 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-06-04T03:55:42.6465889Z Jun 04 03:55:42 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-06-04T03:55:42.6467232Z Jun 04 03:55:42 at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-06-04T03:55:42.6468402Z Jun 04 03:55:42 at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-06-04T03:55:42.6469590Z Jun 04 03:55:42 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-06-04T03:55:42.6471024Z Jun 04 03:55:42 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-06-04T03:55:42.6472343Z Jun 04 03:55:42 at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-06-04T03:55:42.6473784Z Jun 04 03:55:42 at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-06-04T03:55:42.6475031Z Jun 04 03:55:42 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
2022-06-04T03:55:42.6476470Z Jun 04 03:55:42 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2022-06-04T03:55:42.6477643Z Jun 04 03:55:42 at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2022-06-04T03:55:42.6478657Z Jun 04 03:55:42 at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2022-06-04T03:55:42.6479701Z Jun 04 03:55:42 at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2022-06-04T03:55:42.6481049Z Jun 04 03:55:42 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-06-04T03:55:42.6482125Z Jun 04 03:55:42 at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2022-06-04T03:55:42.6483906Z Jun 04 03:55:42 at
akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2022-06-04T03:55:42.6485102Z Jun 04 03:55:42 at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2022-06-04T03:55:42.6486234Z Jun 04 03:55:42 at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2022-06-04T03:55:42.6487304Z Jun 04 03:55:42 at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2022-06-04T03:55:42.6488468Z Jun 04 03:55:42 at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2022-06-04T03:55:42.6489732Z Jun 04 03:55:42 at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2022-06-04T03:55:42.6491079Z Jun 04 03:55:42 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-06-04T03:55:42.6492305Z Jun 04 03:55:42 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-06-04T03:55:42.6493625Z Jun 04 03:55:42 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-06-04T03:55:42.6494749Z Jun 04 03:55:42 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-06-04T03:55:42.6495665Z Jun 04 03:55:42 Caused by:
org.apache.flink.runtime.JobException: Recovery is suppressed by
FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0)
2022-06-04T03:55:42.6496537Z Jun 04 03:55:42 at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.howToHandleFailure(AdaptiveScheduler.java:1098)
2022-06-04T03:55:42.6497704Z Jun 04 03:55:42 at
org.apache.flink.runtime.scheduler.adaptive.Executing.onFailure(Executing.java:93)
2022-06-04T03:55:42.6499063Z Jun 04 03:55:42 at
org.apache.flink.runtime.scheduler.adaptive.StateWithExecutionGraph.updateTaskExecutionState(StateWithExecutionGraph.java:363)
2022-06-04T03:55:42.6500566Z Jun 04 03:55:42 at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.lambda$updateTaskExecutionState$4(AdaptiveScheduler.java:496)
2022-06-04T03:55:42.6501955Z Jun 04 03:55:42 at
org.apache.flink.runtime.scheduler.adaptive.State.tryCall(State.java:137)
2022-06-04T03:55:42.6503359Z Jun 04 03:55:42 at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.updateTaskExecutionState(AdaptiveScheduler.java:493)
2022-06-04T03:55:42.6505053Z Jun 04 03:55:42 at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
2022-06-04T03:55:42.6506468Z Jun 04 03:55:42 at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
2022-06-04T03:55:42.6507609Z Jun 04 03:55:42 at
sun.reflect.GeneratedMethodAccessor12.invoke(Unknown Source)
2022-06-04T03:55:42.6508833Z Jun 04 03:55:42 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-06-04T03:55:42.6510061Z Jun 04 03:55:42 at
java.lang.reflect.Method.invoke(Method.java:498)
2022-06-04T03:55:42.6511278Z Jun 04 03:55:42 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2022-06-04T03:55:42.6512823Z Jun 04 03:55:42 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-06-04T03:55:42.6514580Z Jun 04 03:55:42 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2022-06-04T03:55:42.6516045Z Jun 04 03:55:42 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2022-06-04T03:55:42.6517482Z Jun 04 03:55:42 at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2022-06-04T03:55:42.6518724Z Jun 04 03:55:42 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2022-06-04T03:55:42.6520127Z Jun 04 03:55:42 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-06-04T03:55:42.6521314Z Jun 04 03:55:42 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-06-04T03:55:42.6522568Z Jun 04 03:55:42 at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-06-04T03:55:42.6524042Z Jun 04 03:55:42 at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-06-04T03:55:42.6525250Z Jun 04 03:55:42 at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-06-04T03:55:42.6526297Z Jun 04 03:55:42 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-06-04T03:55:42.6527545Z Jun 04 03:55:42 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-06-04T03:55:42.6528604Z Jun 04 03:55:42 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-06-04T03:55:42.6529577Z Jun 04 03:55:42 at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-06-04T03:55:42.6530600Z Jun 04 03:55:42 at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-06-04T03:55:42.6531636Z Jun 04 03:55:42 at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-06-04T03:55:42.6532753Z Jun 04 03:55:42 at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-06-04T03:55:42.6534065Z Jun 04 03:55:42 at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-06-04T03:55:42.6535006Z Jun 04 03:55:42 at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-06-04T03:55:42.6536025Z Jun 04 03:55:42 at
akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-06-04T03:55:42.6537041Z Jun 04 03:55:42 at
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-06-04T03:55:42.6537841Z Jun 04 03:55:42 ... 4 more
2022-06-04T03:55:42.6538579Z Jun 04 03:55:42 Caused by: java.io.IOException:
java.lang.InterruptedException
2022-06-04T03:55:42.6539865Z Jun 04 03:55:42 at
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.close(ChannelStateWriteRequestExecutorImpl.java:175)
2022-06-04T03:55:42.6541437Z Jun 04 03:55:42 at
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriterImpl.close(ChannelStateWriterImpl.java:234)
2022-06-04T03:55:42.6542346Z Jun 04 03:55:42 at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.cancel(SubtaskCheckpointCoordinatorImpl.java:560)
2022-06-04T03:55:42.6543391Z Jun 04 03:55:42 at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.close(SubtaskCheckpointCoordinatorImpl.java:547)
2022-06-04T03:55:42.6544264Z Jun 04 03:55:42 at
org.apache.flink.util.IOUtils.closeAll(IOUtils.java:254)
2022-06-04T03:55:42.6544944Z Jun 04 03:55:42 at
org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:72)
2022-06-04T03:55:42.6545716Z Jun 04 03:55:42 at
org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127)
2022-06-04T03:55:42.6546474Z Jun 04 03:55:42 at
org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:938)
2022-06-04T03:55:42.6547185Z Jun 04 03:55:42 at
org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$1(Task.java:923)
2022-06-04T03:55:42.6547911Z Jun 04 03:55:42 at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
2022-06-04T03:55:42.6548623Z Jun 04 03:55:42 at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:923)
2022-06-04T03:55:42.6549274Z Jun 04 03:55:42 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
2022-06-04T03:55:42.6549907Z Jun 04 03:55:42 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
2022-06-04T03:55:42.6550468Z Jun 04 03:55:42 at
java.lang.Thread.run(Thread.java:748)
2022-06-04T03:55:42.6550943Z Jun 04 03:55:42 Caused by:
java.lang.InterruptedException
2022-06-04T03:55:42.6551520Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:347)
2022-06-04T03:55:42.6552200Z Jun 04 03:55:42 at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2022-06-04T03:55:42.6553308Z Jun 04 03:55:42 at
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequest.lambda$buildFutureWriteRequest$4(ChannelStateWriteRequest.java:113)
2022-06-04T03:55:42.6554458Z Jun 04 03:55:42 at
org.apache.flink.runtime.checkpoint.channel.CheckpointInProgressRequest.cancel(ChannelStateWriteRequest.java:253)
2022-06-04T03:55:42.6555409Z Jun 04 03:55:42 at
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.lambda$null$1(ChannelStateWriteRequestExecutorImpl.java:117)
2022-06-04T03:55:42.6556225Z Jun 04 03:55:42 at
org.apache.flink.util.IOUtils.closeAll(IOUtils.java:254)
2022-06-04T03:55:42.6556817Z Jun 04 03:55:42 at
org.apache.flink.util.IOUtils.closeAll(IOUtils.java:233)
2022-06-04T03:55:42.6557629Z Jun 04 03:55:42 at
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.cleanupRequests(ChannelStateWriteRequestExecutorImpl.java:115)
2022-06-04T03:55:42.6558443Z Jun 04 03:55:42 at
org.apache.flink.util.IOUtils.closeAll(IOUtils.java:254)
2022-06-04T03:55:42.6559148Z Jun 04 03:55:42 at
org.apache.flink.util.IOUtils.closeAll(IOUtils.java:233)
2022-06-04T03:55:42.6559727Z Jun 04 03:55:42 at
org.apache.flink.util.IOUtils.closeAll(IOUtils.java:222)
2022-06-04T03:55:42.6560480Z Jun 04 03:55:42 at
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.run(ChannelStateWriteRequestExecutorImpl.java:80)
2022-06-04T03:55:42.6561119Z Jun 04 03:55:42 ... 1 more
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=36302&view=logs&j=f2c100be-250b-5e85-7bbe-176f68fcddc5&t=05efd11e-5400-54a4-0d27-a4663be008a9
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
