[
https://issues.apache.org/jira/browse/FLINK-21428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288899#comment-17288899
]
Robert Metzger commented on FLINK-21428:
----------------------------------------
Is this the same issue ?
https://dev.azure.com/rmetzger/Flink/_build/results?buildId=8910&view=logs&j=9dc1b5dc-bcfa-5f83-eaa7-0cb181ddc267&t=ab910030-93db-52a7-74a3-34a0addb481b
{{HistoryServerTest.testRemainExpiredJob}} runs a job 3 times in a row, and
fails with:
{code}
2021-02-22T21:07:03.2332599Z [ERROR] testRemainExpiredJob[Flink version less
than 1.4: true](org.apache.flink.runtime.webmonitor.history.HistoryServerTest)
Time elapsed: 13.125 s <<< ERROR!
2021-02-22T21:07:03.2333649Z
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2021-02-22T21:07:03.2334391Z at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2021-02-22T21:07:03.2335245Z at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
2021-02-22T21:07:03.2336066Z at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2021-02-22T21:07:03.2336801Z at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2021-02-22T21:07:03.2337748Z at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2021-02-22T21:07:03.2338484Z at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2021-02-22T21:07:03.2339273Z at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237)
2021-02-22T21:07:03.2340063Z at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2021-02-22T21:07:03.2340818Z at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2021-02-22T21:07:03.2341556Z at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2021-02-22T21:07:03.2342278Z at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2021-02-22T21:07:03.2343004Z at
org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1066)
2021-02-22T21:07:03.2343682Z at
akka.dispatch.OnComplete.internal(Future.scala:264)
2021-02-22T21:07:03.2345261Z at
akka.dispatch.OnComplete.internal(Future.scala:261)
2021-02-22T21:07:03.2345779Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
2021-02-22T21:07:03.2346297Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
2021-02-22T21:07:03.2346814Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2021-02-22T21:07:03.2347412Z at
org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73)
2021-02-22T21:07:03.2348039Z at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
2021-02-22T21:07:03.2348624Z at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
2021-02-22T21:07:03.2349174Z at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
2021-02-22T21:07:03.2349766Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
2021-02-22T21:07:03.2350434Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
2021-02-22T21:07:03.2351157Z at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
2021-02-22T21:07:03.2351712Z at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
2021-02-22T21:07:03.2352251Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2021-02-22T21:07:03.2352829Z at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
2021-02-22T21:07:03.2353496Z at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
2021-02-22T21:07:03.2354173Z at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2021-02-22T21:07:03.2354832Z at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2021-02-22T21:07:03.2355444Z at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
2021-02-22T21:07:03.2356028Z at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
2021-02-22T21:07:03.2356606Z at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
2021-02-22T21:07:03.2357222Z at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
2021-02-22T21:07:03.2357846Z at
akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2021-02-22T21:07:03.2358415Z at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2021-02-22T21:07:03.2359157Z at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2021-02-22T21:07:03.2359744Z at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2021-02-22T21:07:03.2360383Z Caused by:
org.apache.flink.runtime.client.JobExecutionException: Not enough resources
available for scheduling.
2021-02-22T21:07:03.2361194Z at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.lambda$determineParallelismAndAssignResources$18(AdaptiveScheduler.java:584)
2021-02-22T21:07:03.2361867Z at
java.util.Optional.orElseThrow(Optional.java:290)
2021-02-22T21:07:03.2362598Z at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.determineParallelismAndAssignResources(AdaptiveScheduler.java:581)
2021-02-22T21:07:03.2363423Z at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.createExecutionGraphWithAvailableResources(AdaptiveScheduler.java:597)
2021-02-22T21:07:03.2366031Z at
org.apache.flink.runtime.scheduler.adaptive.WaitingForResources.createExecutionGraphWithAvailableResources(WaitingForResources.java:105)
2021-02-22T21:07:03.2367062Z at
org.apache.flink.runtime.scheduler.adaptive.WaitingForResources.resourceTimeout(WaitingForResources.java:99)
2021-02-22T21:07:03.2367924Z at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.runIfState(AdaptiveScheduler.java:897)
2021-02-22T21:07:03.2368768Z at
org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.lambda$runIfState$20(AdaptiveScheduler.java:912)
2021-02-22T21:07:03.2369554Z at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2021-02-22T21:07:03.2370238Z at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
2021-02-22T21:07:03.2371437Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440)
2021-02-22T21:07:03.2372210Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208)
2021-02-22T21:07:03.2372998Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
2021-02-22T21:07:03.2373911Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
2021-02-22T21:07:03.2374808Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2021-02-22T21:07:03.2376929Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2021-02-22T21:07:03.2378639Z at
scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
2021-02-22T21:07:03.2379351Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2021-02-22T21:07:03.2380046Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
2021-02-22T21:07:03.2380905Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2021-02-22T21:07:03.2381574Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2021-02-22T21:07:03.2383110Z at
akka.actor.Actor$class.aroundReceive(Actor.scala:517)
2021-02-22T21:07:03.2383786Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2021-02-22T21:07:03.2384446Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2021-02-22T21:07:03.2385113Z at
akka.actor.ActorCell.invoke(ActorCell.scala:561)
2021-02-22T21:07:03.2385758Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2021-02-22T21:07:03.2386361Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2021-02-22T21:07:03.2386926Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2021-02-22T21:07:03.2387435Z ... 4 more
{code}
> DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing
> fail
> ----------------------------------------------------------------------------------
>
> Key: FLINK-21428
> URL: https://issues.apache.org/jira/browse/FLINK-21428
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.13.0
> Reporter: Guowei Ma
> Assignee: Matthias
> Priority: Critical
> Labels: test-stability
> Fix For: 1.13.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13510&view=logs&j=d8d26c26-7ec2-5ed2-772e-7a1a1eb8317c&t=be5fb08e-1ad7-563c-4f1a-a97ad4ce4865
> {code:java}
> [ERROR] Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed:
> 23.313 s <<< FAILURE! - in
> org.apache.flink.runtime.scheduler.declarative.DeclarativeSchedulerSlotSharingITCase
> [ERROR]
> testSchedulingOfJobRequiringSlotSharing(org.apache.flink.runtime.scheduler.declarative.DeclarativeSchedulerSlotSharingITCase)
> Time elapsed: 20.683 s <<< ERROR!
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> at
> org.apache.flink.runtime.scheduler.declarative.DeclarativeSchedulerSlotSharingITCase.runJob(DeclarativeSchedulerSlotSharingITCase.java:83)
> at
> org.apache.flink.runtime.scheduler.declarative.DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing(DeclarativeSchedulerSlotSharingITCase.java:71)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498) at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
> at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55) at
> org.junit.rules.RunRules.evaluate(RunRules.java:20) at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325) at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) at
> org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
