You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/23 08:12:00 UTC

[jira] [Closed] (FLINK-28210) FlinkSessionJob fails after FlinkDeployment is updated

     [ https://issues.apache.org/jira/browse/FLINK-28210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gyula Fora closed FLINK-28210.
------------------------------
    Resolution: Won't Fix

> FlinkSessionJob fails after FlinkDeployment is updated
> ------------------------------------------------------
>
>                 Key: FLINK-28210
>                 URL: https://issues.apache.org/jira/browse/FLINK-28210
>             Project: Flink
>          Issue Type: Bug
>          Components: Kubernetes Operator
>    Affects Versions: kubernetes-operator-1.0.0
>         Environment: The [quick start|https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/try-flink-kubernetes-operator/quick-start/] was followed to install minikube and the flink operator. 
>  
> minikube 1.24.1
> kubectl 1.24.2
> flink operator: 1.0.0
>            Reporter: Daniel Crowe
>            Priority: Major
>
> I created a flink deployment using this example:
> {code}
> curl https://raw.githubusercontent.com/apache/flink-kubernetes-operator/main/examples/basic-session-job.yaml -o basic-session-job.yaml 
> kubectl create -f basic-session-job.yaml 
> {code}
> Then, I modified the memory allocated to the jobManager and applied the change
> {code}
> kubectl apply -f basic-session-job.yaml 
> {code}
> The job manager is restarted to apply the change, but the jobs are not. 
> Looking at the operator logs, it appears that something is failing during job status observation:
> {noformat}
> 2022-06-23 03:29:51,189 o.a.f.k.o.c.FlinkSessionJobController [INFO ][default/basic-session-job-example2] Starting reconciliation
> 2022-06-23 03:29:51,190 o.a.f.k.o.o.JobStatusObserver  [INFO ][default/basic-session-job-example2] Observing job status
> 2022-06-23 03:29:51,205 o.a.f.k.o.c.FlinkSessionJobController [INFO ][default/basic-session-job-example] Starting reconciliation
> 2022-06-23 03:29:51,206 o.a.f.k.o.o.JobStatusObserver  [INFO ][default/basic-session-job-example] Observing job status
> 2022-06-23 03:29:51,208 o.a.f.k.o.c.FlinkDeploymentController [INFO ][default/basic-session-cluster] Starting reconciliation
> 2022-06-23 03:29:51,227 o.a.f.k.o.c.FlinkDeploymentController [INFO ][default/basic-session-cluster] End of reconciliation
> {noformat}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)