[
https://issues.apache.org/jira/browse/FLINK-26554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503689#comment-17503689
]
Thomas Weise commented on FLINK-26554:
--------------------------------------
{code:java}
java.util.concurrent.TimeoutException
at
java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at
org.apache.flink.kubernetes.operator.service.FlinkService.listJobs(FlinkService.java:134)
at
org.apache.flink.kubernetes.operator.observer.Observer.observeFlinkJobStatus(Observer.java:143)
at
org.apache.flink.kubernetes.operator.observer.Observer.observe(Observer.java:64)
at
org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.cleanup(FlinkDeploymentController.java:98)
at
org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.cleanup(FlinkDeploymentController.java:56)
at
io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:68)
at
io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:50)
at
io.javaoperatorsdk.operator.api.monitoring.Metrics.timeControllerExecution(Metrics.java:34)
at
io.javaoperatorsdk.operator.processing.Controller.cleanup(Controller.java:49)
at
io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleCleanup(ReconciliationDispatcher.java:260)
at
io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleDispatch(ReconciliationDispatcher.java:80)
at
io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleExecution(ReconciliationDispatcher.java:51)
at
io.javaoperatorsdk.operator.processing.event.EventProcessor$ControllerExecution.run(EventProcessor.java:385)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829) {code}
> Clean termination of FlinkDeployment
> ------------------------------------
>
> Key: FLINK-26554
> URL: https://issues.apache.org/jira/browse/FLINK-26554
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
> Reporter: Thomas Weise
> Priority: Major
>
> After stopping the deployment, operator attempts to list jobs:
> 2022-03-09 07:55:37,114 o.a.f.k.o.u.FlinkUtils [INFO ]
> [default.basic-example] Waiting for cluster shutdown... (16)
> 2022-03-09 07:55:38,123 o.a.f.k.o.u.FlinkUtils [INFO ]
> [default.basic-example] Cluster shutdown completed.
> 2022-03-09 07:55:38,160 o.a.f.k.o.c.FlinkDeploymentController [INFO ]
> [default.basic-example] Stopping cluster basic-example
> 2022-03-09 07:55:38,160 o.a.f.k.o.o.Observer [INFO ]
> [default.basic-example] Getting job statuses for basic-example
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
