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/04/14 10:46:00 UTC
[jira] [Commented] (FLINK-27249) Change the state field in the FlinkSessionJob.Spec.Job into desiredState
[ https://issues.apache.org/jira/browse/FLINK-27249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522233#comment-17522233 ]
Gyula Fora commented on FLINK-27249:
------------------------------------
In general everything in the Spec is "desired". I don't really see the point in adding it there
> Change the state field in the FlinkSessionJob.Spec.Job into desiredState
> ------------------------------------------------------------------------
>
> Key: FLINK-27249
> URL: https://issues.apache.org/jira/browse/FLINK-27249
> Project: Flink
> Issue Type: Improvement
> Components: Kubernetes Operator
> Reporter: Xin Hao
> Priority: Minor
>
> {code:java}
> /** Desired state for the job. */
> private JobState state = JobState.RUNNING; {code}
> It will confuse the users when getting info from the K8s. Such as
> {code:java}
> spec:
> clusterId: session-cluster-test
> job:
> jarURI: file:///flink-examples-streaming_2.12-1.14.4-TopSpeedWindowing.jar
> state: running
> ...
> status:
> jobStatus:
> jobId: 42bf3c6f2ac1d909b054b75c20c30afe
> state: RUNNING
> ...{code}
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)