[
https://issues.apache.org/jira/browse/FLINK-20521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247909#comment-17247909
]
Matthias commented on FLINK-20521:
----------------------------------
Just for documentation purposes as this issue is already in the process of
being resolved: [This
build|https://dev.azure.com/mapohl/flink/_build/results?buildId=137&view=logs&j=0a15d512-44ac-5ba5-97ab-13a5d066c22c&t=634cd701-c189-5dff-24cb-606ed884db87]
failed due to a timeout which looks like being related to this issue.
{code:java}
2020-12-11T04:08:07.7372503Z [ERROR] Tests run: 10, Failures: 0, Errors: 2,
Skipped: 0, Time elapsed: 554.133 s <<< FAILURE! - in
org.apache.flink.test.checkpointing.UnalignedCheckpointITCase
2020-12-11T04:08:07.7373566Z [ERROR] execute[Parallel cogroup, p =
10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) Time
elapsed: 300.162 s <<< ERROR!
2020-12-11T04:08:07.7374137Z org.junit.runners.model.TestTimedOutException:
test timed out after 300 seconds
2020-12-11T04:08:07.7381510Z at sun.misc.Unsafe.park(Native Method)
2020-12-11T04:08:07.7381840Z at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
2020-12-11T04:08:07.7382291Z at
java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
2020-12-11T04:08:07.7382782Z at
java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
2020-12-11T04:08:07.7383266Z at
java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
2020-12-11T04:08:07.7383743Z at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2020-12-11T04:08:07.7384367Z at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1842)
2020-12-11T04:08:07.7384982Z at
org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:70)
2020-12-11T04:08:07.7385641Z at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1822)
2020-12-11T04:08:07.7386146Z at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1804)
2020-12-11T04:08:07.7386810Z at
org.apache.flink.test.checkpointing.UnalignedCheckpointTestBase.execute(UnalignedCheckpointTestBase.java:122)
2020-12-11T04:08:07.7387382Z at
org.apache.flink.test.checkpointing.UnalignedCheckpointITCase.execute(UnalignedCheckpointITCase.java:159)
2020-12-11T04:08:07.7387800Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-12-11T04:08:07.7388165Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-12-11T04:08:07.7388744Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-12-11T04:08:07.7389130Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-12-11T04:08:07.7389538Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-12-11T04:08:07.7389993Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-12-11T04:08:07.7390446Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-12-11T04:08:07.7391069Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-12-11T04:08:07.7391463Z at
org.junit.rules.Verifier$1.evaluate(Verifier.java:35)
2020-12-11T04:08:07.7391831Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-12-11T04:08:07.7392483Z at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
2020-12-11T04:08:07.7393011Z at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
2020-12-11T04:08:07.7393443Z at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
2020-12-11T04:08:07.7393776Z at java.lang.Thread.run(Thread.java:748)
2020-12-11T04:08:07.7393952Z
2020-12-11T04:08:07.7789797Z [ERROR] execute[Parallel union, p =
10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) Time
elapsed: 118.969 s <<< ERROR!
2020-12-11T04:08:07.7790405Z
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2020-12-11T04:08:07.7790949Z at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
2020-12-11T04:08:07.7791480Z at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:119)
2020-12-11T04:08:07.7791989Z at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2020-12-11T04:08:07.7792447Z at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2020-12-11T04:08:07.7792901Z at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-12-11T04:08:07.7793328Z at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2020-12-11T04:08:07.7793836Z at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:229)
2020-12-11T04:08:07.7794479Z at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2020-12-11T04:08:07.7794942Z at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2020-12-11T04:08:07.7795419Z at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-12-11T04:08:07.7795846Z at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2020-12-11T04:08:07.7796304Z at
org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:996)
2020-12-11T04:08:07.7796692Z at
akka.dispatch.OnComplete.internal(Future.scala:264)
2020-12-11T04:08:07.7797023Z at
akka.dispatch.OnComplete.internal(Future.scala:261)
2020-12-11T04:08:07.7797385Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
2020-12-11T04:08:07.7797735Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
2020-12-11T04:08:07.7798094Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2020-12-11T04:08:07.7798554Z at
org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74)
2020-12-11T04:08:07.7799011Z at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
2020-12-11T04:08:07.7799424Z at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
2020-12-11T04:08:07.7799831Z at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
2020-12-11T04:08:07.7800253Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
2020-12-11T04:08:07.7800754Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
2020-12-11T04:08:07.7801295Z at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
2020-12-11T04:08:07.7801680Z at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
2020-12-11T04:08:07.7802052Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2020-12-11T04:08:07.7802490Z at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
2020-12-11T04:08:07.7802980Z at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
2020-12-11T04:08:07.7803490Z at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2020-12-11T04:08:07.7804007Z at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2020-12-11T04:08:07.7804454Z at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
2020-12-11T04:08:07.7804997Z at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
2020-12-11T04:08:07.7805350Z at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
2020-12-11T04:08:07.7805739Z at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
2020-12-11T04:08:07.7806160Z at
akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2020-12-11T04:08:07.7806515Z at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2020-12-11T04:08:07.7806871Z at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2020-12-11T04:08:07.7807250Z at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2020-12-11T04:08:07.7807713Z Caused by: org.apache.flink.runtime.JobException:
Recovery is suppressed by
FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=5,
backoffTimeMS=100)
2020-12-11T04:08:07.7808257Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:116)
2020-12-11T04:08:07.7809035Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
2020-12-11T04:08:07.7809618Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:224)
2020-12-11T04:08:07.7810154Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:217)
2020-12-11T04:08:07.7810748Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:208)
2020-12-11T04:08:07.7811280Z at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:610)
2020-12-11T04:08:07.7811914Z at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:60)
2020-12-11T04:08:07.7812578Z at
org.apache.flink.runtime.executiongraph.ExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(ExecutionGraph.java:1743)
2020-12-11T04:08:07.7813106Z at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1313)
2020-12-11T04:08:07.7813579Z at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1257)
2020-12-11T04:08:07.7814024Z at
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:1091)
2020-12-11T04:08:07.7814480Z at
org.apache.flink.runtime.executiongraph.Execution.lambda$deploy$11(Execution.java:770)
2020-12-11T04:08:07.7814961Z at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2020-12-11T04:08:07.7815421Z at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2020-12-11T04:08:07.7815908Z at
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
2020-12-11T04:08:07.7816357Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:404)
2020-12-11T04:08:07.7816816Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:197)
2020-12-11T04:08:07.7817373Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
2020-12-11T04:08:07.7817853Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:154)
2020-12-11T04:08:07.7818264Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2020-12-11T04:08:07.7818651Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2020-12-11T04:08:07.7819026Z at
scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
2020-12-11T04:08:07.7819414Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2020-12-11T04:08:07.7819828Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
2020-12-11T04:08:07.7820219Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-12-11T04:08:07.7820603Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-12-11T04:08:07.7820985Z at
akka.actor.Actor$class.aroundReceive(Actor.scala:517)
2020-12-11T04:08:07.7821339Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2020-12-11T04:08:07.7821791Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2020-12-11T04:08:07.7822098Z at
akka.actor.ActorCell.invoke(ActorCell.scala:561)
2020-12-11T04:08:07.7822388Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2020-12-11T04:08:07.7822666Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2020-12-11T04:08:07.7822949Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2020-12-11T04:08:07.7823143Z ... 4 more
2020-12-11T04:08:07.7823792Z Caused by:
java.util.concurrent.CompletionException:
java.util.concurrent.TimeoutException: Invocation of public abstract
java.util.concurrent.CompletableFuture
org.apache.flink.runtime.taskexecutor.TaskExecutorGateway.submitTask(org.apache.flink.runtime.deployment.TaskDeploymentDescriptor,org.apache.flink.runtime.jobmaster.JobMasterId,org.apache.flink.api.common.time.Time)
timed out.
2020-12-11T04:08:07.7824597Z at
java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
2020-12-11T04:08:07.7824977Z at
java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
2020-12-11T04:08:07.7825377Z at
java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:925)
2020-12-11T04:08:07.7825796Z at
java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:913)
2020-12-11T04:08:07.7826203Z at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-12-11T04:08:07.7826597Z at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2020-12-11T04:08:07.7827037Z at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:227)
2020-12-11T04:08:07.7827489Z at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2020-12-11T04:08:07.7827894Z at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2020-12-11T04:08:07.7828295Z at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-12-11T04:08:07.7828712Z at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2020-12-11T04:08:07.7829111Z at
org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:994)
2020-12-11T04:08:07.7829452Z at
akka.dispatch.OnComplete.internal(Future.scala:263)
2020-12-11T04:08:07.7829762Z at
akka.dispatch.OnComplete.internal(Future.scala:261)
2020-12-11T04:08:07.7830056Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
2020-12-11T04:08:07.7830359Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
2020-12-11T04:08:07.7830690Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2020-12-11T04:08:07.7831209Z at
org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74)
2020-12-11T04:08:07.7831713Z at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
2020-12-11T04:08:07.7832072Z at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
2020-12-11T04:08:07.7832434Z at
akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:644)
2020-12-11T04:08:07.7832780Z at
akka.actor.Scheduler$$anon$4.run(Scheduler.scala:205)
2020-12-11T04:08:07.7833128Z at
scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601)
2020-12-11T04:08:07.7833507Z at
scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109)
2020-12-11T04:08:07.7833891Z at
scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599)
2020-12-11T04:08:07.7834299Z at
akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:328)
2020-12-11T04:08:07.7834755Z at
akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:279)
2020-12-11T04:08:07.7835225Z at
akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:283)
2020-12-11T04:08:07.7835647Z at
akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:235)
2020-12-11T04:08:07.7835970Z at java.lang.Thread.run(Thread.java:748)
2020-12-11T04:08:07.7836624Z Caused by: java.util.concurrent.TimeoutException:
Invocation of public abstract java.util.concurrent.CompletableFuture
org.apache.flink.runtime.taskexecutor.TaskExecutorGateway.submitTask(org.apache.flink.runtime.deployment.TaskDeploymentDescriptor,org.apache.flink.runtime.jobmaster.JobMasterId,org.apache.flink.api.common.time.Time)
timed out.
2020-12-11T04:08:07.7837361Z at
org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway.submitTask(RpcTaskManagerGateway.java:72)
2020-12-11T04:08:07.7837812Z at
org.apache.flink.runtime.executiongraph.Execution.lambda$deploy$10(Execution.java:756)
2020-12-11T04:08:07.7838211Z at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
2020-12-11T04:08:07.7838582Z at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2020-12-11T04:08:07.7838932Z at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
2020-12-11T04:08:07.7839340Z at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
2020-12-11T04:08:07.7839910Z at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
2020-12-11T04:08:07.7840519Z at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2020-12-11T04:08:07.7841136Z at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2020-12-11T04:08:07.7841473Z ... 1 more
2020-12-11T04:08:07.7842865Z Caused by: akka.pattern.AskTimeoutException: Ask
timed out on [Actor[akka://flink/user/rpc/taskmanager_87#1921737344]] after
[10000 ms]. Message of type
[org.apache.flink.runtime.rpc.messages.LocalRpcInvocation]. A typical reason
for `AskTimeoutException` is that the recipient actor didn't send a reply.
2020-12-11T04:08:07.7843696Z at
akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)
2020-12-11T04:08:07.7844119Z at
akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)
2020-12-11T04:08:07.7844556Z at
akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:648)
2020-12-11T04:08:07.7844993Z at
akka.actor.Scheduler$$anon$4.run(Scheduler.scala:205)
2020-12-11T04:08:07.7845421Z at
scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601)
2020-12-11T04:08:07.7845892Z at
scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109)
2020-12-11T04:08:07.7846368Z at
scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599)
2020-12-11T04:08:07.7846874Z at
akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:328)
2020-12-11T04:08:07.7847464Z at
akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:279)
2020-12-11T04:08:07.7848079Z at
akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:283)
2020-12-11T04:08:07.7848604Z at
akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:235)
2020-12-11T04:08:07.7848964Z ... 1 more{code}
> Null result values are being swallowed by RPC system
> ----------------------------------------------------
>
> Key: FLINK-20521
> URL: https://issues.apache.org/jira/browse/FLINK-20521
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.12.0, 1.11.2
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.13.0, 1.12.1
>
>
> If an RPC method returns a {{null}} value, then it seems that the request
> future won't get completed as reported in FLINK-17921.
> We should either not allow to return {{null}} values as responses or make
> sure that a {{null}} value is properly transmitted to the caller.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
