[jira] [Updated] (FLINK-29536) Add WATCH_NAMESPACES env var to kubernetes operator

[ https://issues.apache.org/jira/browse/FLINK-29536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29536: --- Fix Version/s: (was: kubernetes-operator-1.2.0) > Add WATCH_NAMESPACES env var to kubernetes

[jira] [Closed] (FLINK-29550) example "basic-checkpoint-ha.yaml" not working

[ https://issues.apache.org/jira/browse/FLINK-29550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29550. -- Resolution: Cannot Reproduce The examples are mainly designed for minikube, other kubernetes envs may

[jira] [Commented] (FLINK-29566) Reschedule the cleanup logic if cancel job failed

[ https://issues.apache.org/jira/browse/FLINK-29566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617730#comment-17617730 ] Gyula Fora commented on FLINK-29566: I think this improvement makes sense :)  > Reschedule the

[jira] [Updated] (FLINK-29550) example "basic-checkpoint-ha.yaml" not working

[ https://issues.apache.org/jira/browse/FLINK-29550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29550: --- Affects Version/s: (was: 1.15.0) > example "basic-checkpoint-ha.yaml" not working >

[jira] [Commented] (FLINK-29634) Support periodic checkpoint triggering

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617729#comment-17617729 ] Gyula Fora commented on FLINK-29634: I think savepoint history is mostly important so that the

[jira] [Created] (FLINK-29644) Reference Kubernetes operator from Flink Kubernetes deploy docs

Gyula Fora created FLINK-29644: -- Summary: Reference Kubernetes operator from Flink Kubernetes deploy docs Key: FLINK-29644 URL: https://issues.apache.org/jira/browse/FLINK-29644 Project: Flink

[jira] [Closed] (FLINK-29632) Support nodeSelector in helm template for flink operator deployment

[ https://issues.apache.org/jira/browse/FLINK-29632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29632. -- Fix Version/s: kubernetes-operator-1.3.0 Resolution: Fixed merged to main

[jira] [Closed] (FLINK-29619) Remove redundant MeterView updater thread from KubernetesClientMetrics

[ https://issues.apache.org/jira/browse/FLINK-29619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29619. -- Resolution: Fixed merged to main f1387f723da3f274bcb3268d401d91042064255d > Remove redundant

[jira] [Assigned] (FLINK-29633) Operator doesn't pass initialSavepointPath as fromSavepoint argument

[ https://issues.apache.org/jira/browse/FLINK-29633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29633: -- Assignee: Yaroslav Tkachenko > Operator doesn't pass initialSavepointPath as fromSavepoint

[jira] [Closed] (FLINK-29394) Flink k8s operator observe Flink job restart count

[ https://issues.apache.org/jira/browse/FLINK-29394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29394. -- Resolution: Fixed merged to main 49f796b7c5dae2a441d453b67d7e8bcee3bf > Flink k8s operator

[jira] [Assigned] (FLINK-29619) Remove redundant MeterView updater thread from KubernetesClientMetrics

[ https://issues.apache.org/jira/browse/FLINK-29619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29619: -- Assignee: Matyas Orhidi > Remove redundant MeterView updater thread from

[jira] [Created] (FLINK-29609) Clean up jobmanager deployment on suspend after recording savepoint info

Gyula Fora created FLINK-29609: -- Summary: Clean up jobmanager deployment on suspend after recording savepoint info Key: FLINK-29609 URL: https://issues.apache.org/jira/browse/FLINK-29609 Project: Flink

[jira] [Commented] (FLINK-29607) Simplify controller flow by introducing FlinkControllerContext

[ https://issues.apache.org/jira/browse/FLINK-29607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616383#comment-17616383 ] Gyula Fora commented on FLINK-29607: cc [~matyas]  > Simplify controller flow by introducing

[jira] [Created] (FLINK-29607) Simplify controller flow by introducing FlinkControllerContext

Gyula Fora created FLINK-29607: -- Summary: Simplify controller flow by introducing FlinkControllerContext Key: FLINK-29607 URL: https://issues.apache.org/jira/browse/FLINK-29607 Project: Flink

[jira] [Updated] (FLINK-29607) Simplify controller flow by introducing FlinkControllerContext

[ https://issues.apache.org/jira/browse/FLINK-29607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29607: --- Fix Version/s: kubernetes-operator-1.3.0 > Simplify controller flow by introducing

[jira] [Commented] (FLINK-29482) Ingress always forces ClusterIP rest service type

[ https://issues.apache.org/jira/browse/FLINK-29482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616263#comment-17616263 ] Gyula Fora commented on FLINK-29482: I think based on the slack discussions this is not an issue

[jira] [Closed] (FLINK-29233) Flink Kubernetes Operator example/kustomize not running

[ https://issues.apache.org/jira/browse/FLINK-29233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29233. -- Resolution: Cannot Reproduce > Flink Kubernetes Operator example/kustomize not running >

[jira] [Commented] (FLINK-29588) Add Flink Version and Application Version to Savepoint properties

[ https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616044#comment-17616044 ] Gyula Fora commented on FLINK-29588: We don't really have a concept of application version for

[jira] [Updated] (FLINK-29588) Add Flink Version and Application Version to Savepoint properties

[ https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29588: --- Affects Version/s: (was: kubernetes-operator-1.2.0) > Add Flink Version and Application Version

[jira] [Commented] (FLINK-29588) Add Flink Version and Application Version to Savepoint properties

[ https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616020#comment-17616020 ] Gyula Fora commented on FLINK-29588: Since savepoints are compatible across version upgrades I think

[jira] [Commented] (FLINK-29588) Add Flink Version and Application Version to Savepoint properties

[ https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616018#comment-17616018 ] Gyula Fora commented on FLINK-29588: What do you mean by appVersion here? > Add Flink Version and

[jira] [Commented] (FLINK-29571) Flink configuration only supports Map

[ https://issues.apache.org/jira/browse/FLINK-29571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615181#comment-17615181 ] Gyula Fora commented on FLINK-29571: cc [~twalthr]  > Flink configuration only supports Map >

[jira] [Assigned] (FLINK-29544) Update Flink doc

[ https://issues.apache.org/jira/browse/FLINK-29544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29544: -- Assignee: ConradJam > Update Flink doc > > > Key:

[jira] [Assigned] (FLINK-29543) Jar Run Rest Handler Support Flink Configuration

[ https://issues.apache.org/jira/browse/FLINK-29543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29543: -- Assignee: ConradJam > Jar Run Rest Handler Support Flink Configuration >

[jira] [Updated] (FLINK-28979) Add another owner into the JM deployment's owner references

[ https://issues.apache.org/jira/browse/FLINK-28979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28979: --- Fix Version/s: kubernetes-operator-1.3.0 > Add another owner into the JM deployment's owner

[jira] [Closed] (FLINK-29507) Make e2e tests independent of the current directory

[ https://issues.apache.org/jira/browse/FLINK-29507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29507. -- Resolution: Fixed merged to main 39a275f4f4c306061d37991644f81e4625737e93 > Make e2e tests

[jira] [Closed] (FLINK-28979) Add another owner into the JM deployment's owner references

[ https://issues.apache.org/jira/browse/FLINK-28979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28979. -- Resolution: Fixed merged to main 62eb68c812713378f7f66fde01cf14370a2252e4 > Add another owner into

[jira] [Closed] (FLINK-29535) Flink Operator Certificate renew issue

[ https://issues.apache.org/jira/browse/FLINK-29535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29535. -- Resolution: Duplicate please reopen it in case the other fix is not working > Flink Operator

[jira] [Commented] (FLINK-29535) Flink Operator Certificate renew issue

[ https://issues.apache.org/jira/browse/FLINK-29535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17614104#comment-17614104 ] Gyula Fora commented on FLINK-29535: I think this might be already fixed in 1.2.0:

[jira] [Commented] (FLINK-29501) Allow overriding JobVertex parallelisms during job submission

[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613926#comment-17613926 ] Gyula Fora commented on FLINK-29501: _--- If the parallelism is being tuned as part of an

[jira] [Commented] (FLINK-29501) Allow overriding JobVertex parallelisms during job submission

[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613630#comment-17613630 ] Gyula Fora commented on FLINK-29501: I think [~mxm] makes valid points here.  The problem with the

[jira] [Commented] (FLINK-29131) Kubernetes operator webhook can use hostPort

[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612774#comment-17612774 ] Gyula Fora commented on FLINK-29131: If you feel that it would be enough to extend/rework our helm

[jira] [Resolved] (FLINK-29413) Make it possible to associate triggered and completed savepoints

[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-29413. Resolution: Fixed merged to main 1f6a75056acae90e9fab182fd076ee6755b35bbb > Make it possible to

[jira] [Created] (FLINK-29482) Ingress always forces ClusterIP rest service type

Gyula Fora created FLINK-29482: -- Summary: Ingress always forces ClusterIP rest service type Key: FLINK-29482 URL: https://issues.apache.org/jira/browse/FLINK-29482 Project: Flink Issue Type:

[jira] [Commented] (FLINK-28875) Add FlinkSessionJobControllerTest

[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611397#comment-17611397 ] Gyula Fora commented on FLINK-28875: No worries :) We are not going to include it in the 1.2.0

[jira] [Updated] (FLINK-28645) Clean up logging in FlinkService / Reconciler

[ https://issues.apache.org/jira/browse/FLINK-28645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28645: --- Fix Version/s: kubernetes-operator-1.3.0 (was: kubernetes-operator-1.2.0) >

[jira] [Updated] (FLINK-28875) Add FlinkSessionJobControllerTest

[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28875: --- Fix Version/s: kubernetes-operator-1.3.0 (was: kubernetes-operator-1.2.0) >

[jira] [Commented] (FLINK-29474) Name collision: Group already contains a Metric with the name

[ https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611200#comment-17611200 ] Gyula Fora commented on FLINK-29474: merged to main 3ae66dbddd4126a19c1e8f0105027bc370f5e753 > Name

[jira] [Closed] (FLINK-29474) Name collision: Group already contains a Metric with the name

[ https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29474. -- Resolution: Fixed > Name collision: Group already contains a Metric with the name >

[jira] [Closed] (FLINK-29469) Generate noop.jar instead of committing into source

[ https://issues.apache.org/jira/browse/FLINK-29469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29469. -- Resolution: Fixed merged to main ed433cea2b2ea079b9966fa15c31dc5177e46961 > Generate noop.jar

[jira] [Closed] (FLINK-29464) JobID generation logic could lead to state loss

[ https://issues.apache.org/jira/browse/FLINK-29464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29464. -- Resolution: Fixed merged to main c33e3ef06296974af47b24f499aef71944c60a4d > JobID generation logic

[jira] [Assigned] (FLINK-29474) Name collision: Group already contains a Metric with the name

[ https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29474: -- Assignee: Gyula Fora > Name collision: Group already contains a Metric with the name >

[jira] [Created] (FLINK-29469) Generate noop.jar instead of committing into source

Gyula Fora created FLINK-29469: -- Summary: Generate noop.jar instead of committing into source Key: FLINK-29469 URL: https://issues.apache.org/jira/browse/FLINK-29469 Project: Flink Issue Type:

[jira] [Commented] (FLINK-29465) Supports limit factor in the resource definition

[ https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610906#comment-17610906 ] Gyula Fora commented on FLINK-29465: You can already set this easily through `flinkConfiguration`

[jira] [Commented] (FLINK-29465) Supports limit factor in the resource definition

[ https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610875#comment-17610875 ] Gyula Fora commented on FLINK-29465: What is the limit factor? What does the setting do? > Supports

[jira] [Commented] (FLINK-29464) JobID generation logic could lead to state loss

[ https://issues.apache.org/jira/browse/FLINK-29464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610847#comment-17610847 ] Gyula Fora commented on FLINK-29464: cc [~thw]  > JobID generation logic could lead to state loss >

[jira] [Created] (FLINK-29464) JobID generation logic could lead to state loss

Gyula Fora created FLINK-29464: -- Summary: JobID generation logic could lead to state loss Key: FLINK-29464 URL: https://issues.apache.org/jira/browse/FLINK-29464 Project: Flink Issue Type:

[jira] [Closed] (FLINK-29392) SessionJobs are lost when Session FlinkDeployment is upgraded without HA

[ https://issues.apache.org/jira/browse/FLINK-29392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29392. -- Resolution: Fixed merged to main c4445bcc7d00f774489007a3e961dfa0dae3e38d > SessionJobs are lost

[jira] [Updated] (FLINK-28186) Trigger Operator Events on Configuration Changes

[ https://issues.apache.org/jira/browse/FLINK-28186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28186: --- Fix Version/s: kubernetes-operator-1.3.0 (was: kubernetes-operator-1.2.0) >

[jira] [Closed] (FLINK-29376) Deployment already exists error if Flink version is not set correctly

[ https://issues.apache.org/jira/browse/FLINK-29376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29376. -- Resolution: Fixed merged to main 395956910af19f0ba6f1de1ae4d730aee4b6504f > Deployment already

[jira] [Assigned] (FLINK-29413) Make it possible to associate triggered and completed savepoints

[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29413: -- Assignee: Matyas Orhidi (was: Gyula Fora) > Make it possible to associate triggered and

[jira] [Closed] (FLINK-29384) snakeyaml version 1.30 in flink-kubernetes-operator-1.2-SNAPSHOT-shaded.jar has vulnerabilities

[ https://issues.apache.org/jira/browse/FLINK-29384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29384. -- Resolution: Fixed Merged to main 0952b0dd05f04390f549e3ca20f4ba345b067a18 > snakeyaml version 1.30

[jira] [Updated] (FLINK-29413) Make it possible to associate triggered and completed savepoints

[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29413: --- Fix Version/s: kubernetes-operator-1.3.0 > Make it possible to associate triggered and completed

[jira] [Assigned] (FLINK-29413) Make it possible to associate triggered and completed savepoints

[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29413: -- Assignee: Gyula Fora > Make it possible to associate triggered and completed savepoints >

[jira] [Commented] (FLINK-29413) Make it possible to associate triggered and completed savepoints

[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17609572#comment-17609572 ] Gyula Fora commented on FLINK-29413: We don't really see any other way to retrieve the format info,

[jira] [Closed] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29109. -- Fix Version/s: kubernetes-operator-1.2.0 Resolution: Fixed merged to main

[jira] [Commented] (FLINK-29413) Make it possible to associate triggered and completed savepoints

[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17609537#comment-17609537 ] Gyula Fora commented on FLINK-29413: I guess we could add that too if there is no other way to get

[jira] [Commented] (FLINK-29131) Kubernetes operator webhook can use hostPort

[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17609443#comment-17609443 ] Gyula Fora commented on FLINK-29131: I agree changing the helm chart to have a single Deployment to

[jira] [Commented] (FLINK-29199) Support blue-green deployment type

[ https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17609442#comment-17609442 ] Gyula Fora commented on FLINK-29199: What I was saying is that cluster-id which must be unique

[jira] [Created] (FLINK-29413) Make it possible to associate triggered and completed savepoints

Gyula Fora created FLINK-29413: -- Summary: Make it possible to associate triggered and completed savepoints Key: FLINK-29413 URL: https://issues.apache.org/jira/browse/FLINK-29413 Project: Flink

[jira] [Closed] (FLINK-29159) Revisit/harden initial deployment logic

[ https://issues.apache.org/jira/browse/FLINK-29159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29159. -- Resolution: Fixed merged to main d2161ac99e02af322b38b961b6df2660de812c59 > Revisit/harden initial

[jira] [Assigned] (FLINK-29376) Deployment already exists error if Flink version is not set correctly

[ https://issues.apache.org/jira/browse/FLINK-29376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29376: -- Assignee: Gabor Somogyi (was: Matyas Orhidi) > Deployment already exists error if Flink

[jira] [Updated] (FLINK-27491) Support env replacement in flink-kubernetes-operator CR

[ https://issues.apache.org/jira/browse/FLINK-27491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27491: --- Fix Version/s: kubernetes-operator-1.3.0 > Support env replacement in flink-kubernetes-operator CR

[jira] [Updated] (FLINK-27448) Enable standalone mode for old Flink versions

[ https://issues.apache.org/jira/browse/FLINK-27448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27448: --- Fix Version/s: kubernetes-operator-1.3.0 (was: kubernetes-operator-1.2.0) >

[jira] [Updated] (FLINK-27852) Contribute k8s operator to OperatorHub

[ https://issues.apache.org/jira/browse/FLINK-27852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27852: --- Fix Version/s: (was: kubernetes-operator-1.2.0) > Contribute k8s operator to OperatorHub >

[jira] [Updated] (FLINK-28408) FAQ / best practices page for Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-28408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28408: --- Priority: Minor (was: Major) > FAQ / best practices page for Kubernetes Operator >

[jira] [Updated] (FLINK-28408) FAQ / best practices page for Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-28408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28408: --- Affects Version/s: (was: kubernetes-operator-1.1.0) > FAQ / best practices page for Kubernetes

[jira] [Updated] (FLINK-28594) Add metrics for FlinkService

[ https://issues.apache.org/jira/browse/FLINK-28594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28594: --- Fix Version/s: kubernetes-operator-1.3.0 > Add metrics for FlinkService >

[jira] [Updated] (FLINK-28645) Clean up logging in FlinkService / Reconciler

[ https://issues.apache.org/jira/browse/FLINK-28645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28645: --- Priority: Critical (was: Major) > Clean up logging in FlinkService / Reconciler >

[jira] [Updated] (FLINK-28648) Allow session deletion to block on any running job

[ https://issues.apache.org/jira/browse/FLINK-28648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28648: --- Fix Version/s: kubernetes-operator-1.3.0 > Allow session deletion to block on any running job >

[jira] [Updated] (FLINK-28649) Allow adopting unmanaged jobs as FlinkSessionJob resource

[ https://issues.apache.org/jira/browse/FLINK-28649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28649: --- Fix Version/s: kubernetes-operator-1.3.0 > Allow adopting unmanaged jobs as FlinkSessionJob

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote resourcemanager address

[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29117: --- Affects Version/s: (was: 1.15.1) > Tried to associate with unreachable remote resourcemanager

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote resourcemanager address

[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29117: --- Component/s: (was: flink-contrib) (was: flink-docker) > Tried to associate

[jira] [Closed] (FLINK-29117) Tried to associate with unreachable remote resourcemanager address

[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29117. -- Resolution: Cannot Reproduce I am closing this for now, if you feel that this is still happening for

[jira] [Updated] (FLINK-29159) Revisit/harden initial deployment logic

[ https://issues.apache.org/jira/browse/FLINK-29159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29159: --- Fix Version/s: kubernetes-operator-1.2.0 > Revisit/harden initial deployment logic >

[jira] [Assigned] (FLINK-29159) Revisit/harden initial deployment logic

[ https://issues.apache.org/jira/browse/FLINK-29159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29159: -- Assignee: Gyula Fora > Revisit/harden initial deployment logic >

[jira] [Commented] (FLINK-29131) Kubernetes operator webhook can use hostPort

[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608969#comment-17608969 ] Gyula Fora commented on FLINK-29131: [~dylanmei] are you planning to work on this? > Kubernetes

[jira] [Updated] (FLINK-29131) Kubernetes operator webhook can use hostPort

[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29131: --- Priority: Minor (was: Major) > Kubernetes operator webhook can use hostPort >

[jira] [Updated] (FLINK-29199) Support blue-green deployment type

[ https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29199: --- Priority: Minor (was: Major) > Support blue-green deployment type >

[jira] [Updated] (FLINK-29394) Flink k8s operator observe Flink job restart count

[ https://issues.apache.org/jira/browse/FLINK-29394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29394: --- Fix Version/s: kubernetes-operator-1.3.0 > Flink k8s operator observe Flink job restart count >

[jira] [Updated] (FLINK-29376) Deployment already exists error if Flink version is not set correctly

[ https://issues.apache.org/jira/browse/FLINK-29376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29376: --- Fix Version/s: kubernetes-operator-1.2.0 > Deployment already exists error if Flink version is not

[jira] [Updated] (FLINK-29394) Flink k8s operator observe Flink job restart count

[ https://issues.apache.org/jira/browse/FLINK-29394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29394: --- Affects Version/s: (was: kubernetes-operator-1.1.0) > Flink k8s operator observe Flink job

[jira] [Closed] (FLINK-29391) Add option to set labels and annotations in kubernetes deployment

[ https://issues.apache.org/jira/browse/FLINK-29391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29391. -- Resolution: Not A Problem > Add option to set labels and annotations in kubernetes deployment >

[jira] [Commented] (FLINK-29391) Add option to set labels and annotations in kubernetes deployment

[ https://issues.apache.org/jira/browse/FLINK-29391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608778#comment-17608778 ] Gyula Fora commented on FLINK-29391: you can use the following built in Flink configs:

[jira] [Updated] (FLINK-29392) SessionJobs are lost when Session FlinkDeployment is upgraded without HA

[ https://issues.apache.org/jira/browse/FLINK-29392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29392: --- Fix Version/s: kubernetes-operator-1.2.0 > SessionJobs are lost when Session FlinkDeployment is

[jira] [Closed] (FLINK-29388) Fix args in JobSpec not being passed through to Flink in Standalone mode

[ https://issues.apache.org/jira/browse/FLINK-29388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29388. -- Resolution: Fixed merged to main e2b829c7df7501760dec8f9aa47685c680b227cf > Fix args in JobSpec not

[jira] [Closed] (FLINK-27893) Add additionalPrinterColumns for Job Status and Reconciliation Status in CRDs

[ https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27893. -- Resolution: Duplicate duplicate of FLINK-29383 > Add additionalPrinterColumns for Job Status and

[jira] [Commented] (FLINK-27893) Add additionalPrinterColumns for Job Status and Reconciliation Status in CRDs

[ https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608751#comment-17608751 ] Gyula Fora commented on FLINK-27893: Ah I did not realize that this was a duplicate. Closing > Add

[jira] [Created] (FLINK-29401) Improve observer structure

Gyula Fora created FLINK-29401: -- Summary: Improve observer structure Key: FLINK-29401 URL: https://issues.apache.org/jira/browse/FLINK-29401 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-29382) Flink fails to start when created using quick guide for flink operator

[ https://issues.apache.org/jira/browse/FLINK-29382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29382. -- Resolution: Cannot Reproduce > Flink fails to start when created using quick guide for flink operator

[jira] [Closed] (FLINK-29327) Operator configs are showing up among standard Flink configs

[ https://issues.apache.org/jira/browse/FLINK-29327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29327. -- Resolution: Fixed merged to main 7f7b77cc434e6c2b67071404c5c0a8c0a28e36db > Operator configs are

[jira] [Closed] (FLINK-29383) Add additionalPrinterColumns definition (PrinterColumn annotation) for some status fields

[ https://issues.apache.org/jira/browse/FLINK-29383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29383. -- Fix Version/s: kubernetes-operator-1.2.0 Resolution: Fixed merged to main > Add

[jira] [Comment Edited] (FLINK-29383) Add additionalPrinterColumns definition (PrinterColumn annotation) for some status fields

[ https://issues.apache.org/jira/browse/FLINK-29383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608569#comment-17608569 ] Gyula Fora edited comment on FLINK-29383 at 9/23/22 6:36 AM: - merged to main

[jira] [Closed] (FLINK-29144) Enable multiple jar entries for jarURI

[ https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29144. -- Resolution: Fixed Resolved by 8f53441a4978eeb38dc5ef229c179cc60598ce87 > Enable multiple jar entries

[jira] [Updated] (FLINK-28181) Add support in FlinkSessionJob to submit job using jar available in jobManager's classpath

[ https://issues.apache.org/jira/browse/FLINK-28181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28181: --- Fix Version/s: kubernetes-operator-1.2.0 > Add support in FlinkSessionJob to submit job using jar

[jira] [Updated] (FLINK-29144) Enable multiple jar entries for jarURI

[ https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29144: --- Fix Version/s: kubernetes-operator-1.2.0 > Enable multiple jar entries for jarURI >

[jira] [Closed] (FLINK-28181) Add support in FlinkSessionJob to submit job using jar available in jobManager's classpath

[ https://issues.apache.org/jira/browse/FLINK-28181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28181. -- Resolution: Fixed Resolved by 8f53441a4978eeb38dc5ef229c179cc60598ce87 > Add support in

[jira] [Updated] (FLINK-29288) Can't start a job with a jar in the system classpath

[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29288: --- Fix Version/s: kubernetes-operator-1.2.0 > Can't start a job with a jar in the system classpath >

[jira] [Closed] (FLINK-29288) Can't start a job with a jar in the system classpath

[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29288. -- Resolution: Fixed merged to main 8f53441a4978eeb38dc5ef229c179cc60598ce87 > Can't start a job with a

[jira] [Closed] (FLINK-29393) Upgrade Kubernetes operator examples to use the latest Flink base image

[ https://issues.apache.org/jira/browse/FLINK-29393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29393. -- Resolution: Fixed merged to main 66987fb9b4d6f7a315024cff27dac12886b1ee88 > Upgrade Kubernetes

<    6   7   8   9   10   11   12   13   14   15   >