[
https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311476#comment-17311476
]
hayden zhou commented on FLINK-22047:
-------------------------------------
2021-03-30 09:36:52,903 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
MultipleInput(readOrder=[0,0,0,0,0,1],
members=[\nHashJoin(joinType=[LeftOuterJoin], where=[=(hour0, hour)],
select=[time, hour, appId, pv0, uv, shareCount, likeCount, hour0,
commentCount], isBroadcast=[true], build=[right])\n:- Calc(select=[time, hour,
appId, pv0, uv, shareCount, likeCount])\n: +-
HashJoin(joinType=[LeftOuterJoin], where=[=(hour0, hour)], select=[time, hour,
appId, pv0, uv, shareCount, hour0, likeCount], isBroadcast=[true],
build=[right])\n: :- Calc(select=[time, hour, appId, pv0, uv,
shareCount])\n: : +- HashJoin(joinType=[LeftOuterJoin], where=[=(hour0,
hour)], select=[time, hour, appId, pv0, uv, hour0, shareCount],
build=[right])\n: : :- Calc(select=[time, hour, appId, pv0, uv])\n:
: : +- HashJoin(joinType=[LeftOuterJoin], where=[=(hour0, hour)],
select=[time, hour, appId, pv0, hour0, uv], isBroadcast=[true],
build=[right])\n: : : :- Calc(select=[time, hour, appId, pv AS
pv0])\n: : : : +- HashJoin(joinType=[LeftOuterJoin],
where=[=(hour0, hour)], select=[time, hour, appId, hour0, pv],
build=[right])\n: : : : :- Calc(select=[time, hour, appId])\n:
: : : : +- SortAggregate(isMerge=[true], groupBy=[hour],
select=[hour, Final_MAX(max$0) AS time, Final_MAX(max$1) AS appId])\n: :
: : : +- Sort(orderBy=[hour ASC])\n: : : : :
+- [#6] Exchange(distribution=[hash[hour]])\n: : : : +-
HashAggregate(isMerge=[true], groupBy=[hour], select=[hour,
Final_COUNT(count$0) AS pv])\n: : : : +- [#5]
Exchange(distribution=[hash[hour]])\n: : : +- [#4]
Exchange(distribution=[broadcast])\n: : +-
HashAggregate(isMerge=[true], groupBy=[hour], select=[hour,
Final_COUNT(count$0) AS shareCount])\n: : +- [#3]
Exchange(distribution=[hash[hour]])\n: +- [#2]
Exchange(distribution=[broadcast])\n+- [#1]
Exchange(distribution=[broadcast])\n]) -> Calc(select=[time, hour, appId, (pv0
IS NOT NULL CASE CAST(pv0) CASE 0:BIGINT) AS pv, (uv IS NOT NULL CASE CAST(uv)
CASE 0:BIGINT) AS uv, (shareCount IS NOT NULL CASE CAST(shareCount) CASE
0:BIGINT) AS shareCount, (likeCount IS NOT NULL CASE CAST(likeCount) CASE
0:BIGINT) AS likeCount, (commentCount IS NOT NULL CASE CAST(commentCount) CASE
0:BIGINT) AS commentCount]) -> Sink: Select table sink (1/1)
(262fca25a1e13d9ca47e636f94f8152c) switched from DEPLOYING to RUNNING.
2021-03-30 09:36:53,256 INFO
org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator
[] - Received sink socket server address: /172.16.4.131:41380
2021-03-30 09:36:53,346 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
MultipleInput(readOrder=[0,0,0,0,0,1],
members=[\nHashJoin(joinType=[LeftOuterJoin], where=[=(hour0, hour)],
select=[time, hour, appId, pv0, uv, shareCount, likeCount, hour0,
commentCount], isBroadcast=[true], build=[right])\n:- Calc(select=[time, hour,
appId, pv0, uv, shareCount, likeCount])\n: +-
HashJoin(joinType=[LeftOuterJoin], where=[=(hour0, hour)], select=[time, hour,
appId, pv0, uv, shareCount, hour0, likeCount], isBroadcast=[true],
build=[right])\n: :- Calc(select=[time, hour, appId, pv0, uv,
shareCount])\n: : +- HashJoin(joinType=[LeftOuterJoin], where=[=(hour0,
hour)], select=[time, hour, appId, pv0, uv, hour0, shareCount],
build=[right])\n: : :- Calc(select=[time, hour, appId, pv0, uv])\n:
: : +- HashJoin(joinType=[LeftOuterJoin], where=[=(hour0, hour)],
select=[time, hour, appId, pv0, hour0, uv], isBroadcast=[true],
build=[right])\n: : : :- Calc(select=[time, hour, appId, pv AS
pv0])\n: : : : +- HashJoin(joinType=[LeftOuterJoin],
where=[=(hour0, hour)], select=[time, hour, appId, hour0, pv],
build=[right])\n: : : : :- Calc(select=[time, hour, appId])\n:
: : : : +- SortAggregate(isMerge=[true], groupBy=[hour],
select=[hour, Final_MAX(max$0) AS time, Final_MAX(max$1) AS appId])\n: :
: : : +- Sort(orderBy=[hour ASC])\n: : : : :
+- [#6] Exchange(distribution=[hash[hour]])\n: : : : +-
HashAggregate(isMerge=[true], groupBy=[hour], select=[hour,
Final_COUNT(count$0) AS pv])\n: : : : +- [#5]
Exchange(distribution=[hash[hour]])\n: : : +- [#4]
Exchange(distribution=[broadcast])\n: : +-
HashAggregate(isMerge=[true], groupBy=[hour], select=[hour,
Final_COUNT(count$0) AS shareCount])\n: : +- [#3]
Exchange(distribution=[hash[hour]])\n: +- [#2]
Exchange(distribution=[broadcast])\n+- [#1]
Exchange(distribution=[broadcast])\n]) -> Calc(select=[time, hour, appId, (pv0
IS NOT NULL CASE CAST(pv0) CASE 0:BIGINT) AS pv, (uv IS NOT NULL CASE CAST(uv)
CASE 0:BIGINT) AS uv, (shareCount IS NOT NULL CASE CAST(shareCount) CASE
0:BIGINT) AS shareCount, (likeCount IS NOT NULL CASE CAST(likeCount) CASE
0:BIGINT) AS likeCount, (commentCount IS NOT NULL CASE CAST(commentCount) CASE
0:BIGINT) AS commentCount]) -> Sink: Select table sink (1/1)
(262fca25a1e13d9ca47e636f94f8152c) switched from RUNNING to FINISHED.
2021-03-30 09:36:53,347 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job collect
(714ab4bed51ccb59562691857348cf93) switched from state RUNNING to FINISHED.
2021-03-30 09:36:53,347 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Stopping
checkpoint coordinator for job 714ab4bed51ccb59562691857348cf93.
2021-03-30 09:36:53,347 INFO
org.apache.flink.runtime.checkpoint.DefaultCompletedCheckpointStore [] -
Shutting down
2021-03-30 09:36:53,377 INFO
org.apache.flink.kubernetes.highavailability.KubernetesCheckpointIDCounter [] -
Shutting down.
2021-03-30 09:36:53,377 INFO
org.apache.flink.kubernetes.highavailability.KubernetesCheckpointIDCounter [] -
Removing counter from ConfigMap
mta-changan-dev-xu-714ab4bed51ccb59562691857348cf93-jobmanager-leader
2021-03-30 09:36:53,493 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job
714ab4bed51ccb59562691857348cf93 reached globally terminal state FINISHED.
2021-03-30 09:36:53,494 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Stopping the JobMaster for job
collect(714ab4bed51ccb59562691857348cf93).
2021-03-30 09:36:53,494 INFO
org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] -
Stopping DefaultLeaderRetrievalService.
2021-03-30 09:36:53,494 INFO
org.apache.flink.kubernetes.highavailability.KubernetesLeaderRetrievalDriver []
- Stopping
KubernetesLeaderRetrievalDriver{configMapName='mta-changan-dev-xu-resourcemanager-leader'}.
2021-03-30 09:36:53,494 INFO
org.apache.flink.kubernetes.kubeclient.resources.KubernetesConfigMapWatcher []
- The watcher is closing.
2021-03-30 09:36:53,495 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Suspending
SlotPool.
2021-03-30 09:36:53,495 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Close ResourceManager connection
6bf020424c426ef4b6eba40936eabcc2: Stopping JobMaster for job
collect(714ab4bed51ccb59562691857348cf93)..
2021-03-30 09:36:53,495 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Stopping
SlotPool.
2021-03-30 09:36:53,495 INFO
org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] -
Disconnect job manager
8ae34664ce49f4341c9407aa3a254...@akka.tcp://flink@172.16.4.91:6123/user/rpc/jobmanager_76
for job 714ab4bed51ccb59562691857348cf93 from the resource manager.
2021-03-30 09:36:53,496 INFO
org.apache.flink.runtime.leaderelection.DefaultLeaderElectionService [] -
Stopping DefaultLeaderElectionService.
2021-03-30 09:36:53,496 INFO
org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriver []
- Closing
KubernetesLeaderElectionDriver{configMapName='mta-changan-dev-xu-714ab4bed51ccb59562691857348cf93-jobmanager-leader'}.
2021-03-30 09:36:53,496 INFO
org.apache.flink.kubernetes.kubeclient.resources.KubernetesConfigMapWatcher []
- The watcher is closing.
2021-03-30 09:36:53,505 INFO
org.apache.flink.kubernetes.highavailability.KubernetesLeaderRetrievalDriver []
- Creating a new watch on ConfigMap
mta-changan-dev-xu-a4d7b2b604258bfbb54f166fb2a6207b-jobmanager-leader.
2021-03-30 09:36:53,540 ERROR
org.apache.flink.runtime.rest.handler.job.coordination.ClientCoordinationHandler
[] - Unhandled exception.
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (714ab4bed51ccb59562691857348cf93)
at
org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGateway(Dispatcher.java:894)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.dispatcher.Dispatcher.performOperationOnJobMasterGateway(Dispatcher.java:907)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.dispatcher.Dispatcher.deliverCoordinationRequestToCoordinator(Dispatcher.java:731)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at sun.reflect.GeneratedMethodAccessor74.invoke(Unknown Source) ~[?:?]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_282]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_282]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[flink-dist_2.11-1.12.2.jar:1.12.2]
2021-03-30 09:36:53,644 INFO
org.apache.flink.runtime.jobmanager.DefaultJobGraphStore [] - Removed job
graph 714ab4bed51ccb59562691857348cf93 from
KubernetesStateHandleStore{configMapName='mta-changan-dev-xu-dispatcher-leader'}.
2021-03-30 09:36:53,659 ERROR
org.apache.flink.runtime.rest.handler.job.coordination.ClientCoordinationHandler
[] - Unhandled exception.
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (714ab4bed51ccb59562691857348cf93)
at
org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGateway(Dispatcher.java:894)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.dispatcher.Dispatcher.performOperationOnJobMasterGateway(Dispatcher.java:907)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.dispatcher.Dispatcher.deliverCoordinationRequestToCoordinator(Dispatcher.java:731)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at sun.reflect.GeneratedMethodAccessor74.invoke(Unknown Source) ~[?:?]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_282]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_282]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[flink-dist_2.11-1.12.2.jar:1.12.2]
2021-03-30 09:36:53,767 ERROR
org.apache.flink.runtime.rest.handler.job.coordination.ClientCoordinationHandler
[] - Unhandled exception.
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (714ab4bed51ccb59562691857348cf93)
at
org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGateway(Dispatcher.java:894)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.dispatcher.Dispatcher.performOperationOnJobMasterGateway(Dispatcher.java:907)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.dispatcher.Dispatcher.deliverCoordinationRequestToCoordinator(Dispatcher.java:731)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at sun.reflect.GeneratedMethodAccessor74.invoke(Unknown Source) ~[?:?]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_282]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_282]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
~[flink-dist_2.11-1.12.2.jar:1.12.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[flink-dist_2.11-1.12.2.jar:1.12.2]
at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[flink-dist_2.11-1.12.2.jar:1.12.2]
> Could not find FLINSHED Flink job and can't submit job
> -------------------------------------------------------
>
> Key: FLINK-22047
> URL: https://issues.apache.org/jira/browse/FLINK-22047
> Project: Flink
> Issue Type: Bug
> Components: Deployment / Kubernetes
> Affects Versions: 1.12.2
> Reporter: hayden zhou
> Priority: Major
> Attachments: screenshot-1.png
>
>
> Could not find FLINSHED Flink job, and aways can't submit job by
> insufficient slot
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
