[jira] [Commented] (FLINK-30408) Add unit test for HA metadata check logic

2022-12-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649891#comment-17649891 ] Gyula Fora commented on FLINK-30408: merged to release-1.3 4e583a0faa0991c61b37ecd9b937fa3e11c6493a

[jira] [Updated] (FLINK-30408) Add unit test for HA metadata check logic

2022-12-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30408: --- Fix Version/s: kubernetes-operator-1.3.1 > Add unit test for HA metadata check logic >

[jira] [Commented] (FLINK-30437) State incompatibility issue might cause state loss

2022-12-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649890#comment-17649890 ] Gyula Fora commented on FLINK-30437: merged to release-1.3 4e583a0faa0991c61b37ecd9b937fa3e11c6493a

[jira] [Updated] (FLINK-30437) State incompatibility issue might cause state loss

2022-12-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30437: --- Fix Version/s: kubernetes-operator-1.3.1 > State incompatibility issue might cause state loss >

[jira] [Commented] (FLINK-28554) Kubernetes-Operator allow readOnlyRootFilesystem via operatorSecurityContext

2022-12-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649740#comment-17649740 ] Gyula Fora commented on FLINK-28554: In that case I suggest we roll back this change, and include

[jira] [Commented] (FLINK-30260) FLIP-271: Add initial Autoscaling implementation

2022-12-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649684#comment-17649684 ] Gyula Fora commented on FLINK-30260: Thank you [~Swathi Chandrashekar]  We will open Jira tickets as

[jira] [Assigned] (FLINK-30456) OLM Bundle Description Version Problems

2022-12-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30456: -- Assignee: James Busche > OLM Bundle Description Version Problems >

[jira] [Closed] (FLINK-30260) FLIP-271: Add initial Autoscaling implementation

2022-12-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30260. -- Fix Version/s: kubernetes-operator-1.4.0 Resolution: Fixed > FLIP-271: Add initial Autoscaling

[jira] [Updated] (FLINK-30437) State incompatibility issue might cause state loss

2022-12-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30437: --- Fix Version/s: kubernetes-operator-1.4.0 > State incompatibility issue might cause state loss >

[jira] [Closed] (FLINK-30408) Add unit test for HA metadata check logic

2022-12-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30408. -- Resolution: Fixed merged to main c4e76402f02f05932c6446d97bdc3d60861b9b27 > Add unit test for HA

[jira] [Closed] (FLINK-30437) State incompatibility issue might cause state loss

2022-12-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30437. -- Resolution: Fixed merged to main c4e76402f02f05932c6446d97bdc3d60861b9b27 > State incompatibility

[jira] [Commented] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2022-12-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649470#comment-17649470 ] Gyula Fora commented on FLINK-30444: I think the JobManager shutting down is inconsistent with the

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

2022-12-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649343#comment-17649343 ] Gyula Fora commented on FLINK-28875: merged to release-1.3 69f7e94808cbded27f2238bf3039b9d693009f4a

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

2022-12-19 Thread Gyula Fora (Jira)
[ 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.1 > Add FlinkSessionJobControllerTest >

[jira] [Commented] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2022-12-18 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648994#comment-17648994 ] Gyula Fora commented on FLINK-30444: This also not consistent with some other startup errors such

[jira] [Commented] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-18 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648977#comment-17648977 ] Gyula Fora commented on FLINK-30411: Thank you[~nowke] , we can backport this to 1.3 after it’s

[jira] [Assigned] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-18 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30411: -- Assignee: Kumar > Flink deployment stuck in UPGRADING state when deploy flinkdeployment

[jira] [Updated] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2022-12-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30444: --- Priority: Critical (was: Major) > State recovery error not handled correctly and always causes JM

[jira] [Created] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2022-12-16 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30444: -- Summary: State recovery error not handled correctly and always causes JM failure Key: FLINK-30444 URL: https://issues.apache.org/jira/browse/FLINK-30444 Project: Flink

[jira] [Commented] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2022-12-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648743#comment-17648743 ] Gyula Fora commented on FLINK-30444: [~dmvk]  > State recovery error not handled correctly and

[jira] [Updated] (FLINK-30437) State incompatibility issue might cause state loss

2022-12-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30437: --- Description: Even though we set: execution.shutdown-on-application-finish: false

[jira] [Updated] (FLINK-30437) State incompatibility issue might cause state loss

2022-12-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30437: --- Summary: State incompatibility issue might cause state loss (was: Last-state upgrade combined with

[jira] [Created] (FLINK-30437) Last-state upgrade combined with state incompatibility causes state loss

2022-12-16 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30437: -- Summary: Last-state upgrade combined with state incompatibility causes state loss Key: FLINK-30437 URL: https://issues.apache.org/jira/browse/FLINK-30437 Project: Flink

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

2022-12-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28875. -- Resolution: Fixed merged to main c8ed11dfde1e0fc57d8fa45b0121ecec362bd03d > Add

[jira] [Closed] (FLINK-30150) Evaluate operator error log whitelist entry: REST service in session cluster is bad now

2022-12-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30150. -- Fix Version/s: kubernetes-operator-1.4.0 Resolution: Fixed merged to main

[jira] [Updated] (FLINK-30361) Cluster deleted and created back while updating replicas

2022-12-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30361: --- Affects Version/s: kubernetes-operator-1.3.0 > Cluster deleted and created back while updating

[jira] [Closed] (FLINK-30361) Cluster deleted and created back while updating replicas

2022-12-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30361. -- Fix Version/s: kubernetes-operator-1.4.0 Resolution: Fixed merged to main

[jira] [Closed] (FLINK-30315) Add more information about image pull failures to the operator log

2022-12-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30315. -- Fix Version/s: kubernetes-operator-1.4.0 Resolution: Fixed merged to main

[jira] [Updated] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30411: --- Affects Version/s: kubernetes-operator-1.3.0 kubernetes-operator-1.2.0

[jira] [Commented] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647012#comment-17647012 ] Gyula Fora commented on FLINK-30411: Could you please work on adding the required extra validation?

[jira] [Created] (FLINK-30408) Add unit test for HA metadata check logic

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30408: -- Summary: Add unit test for HA metadata check logic Key: FLINK-30408 URL: https://issues.apache.org/jira/browse/FLINK-30408 Project: Flink Issue Type:

[jira] [Created] (FLINK-30407) Better encapsulate error handling logic in controllers

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30407: -- Summary: Better encapsulate error handling logic in controllers Key: FLINK-30407 URL: https://issues.apache.org/jira/browse/FLINK-30407 Project: Flink Issue

[jira] [Created] (FLINK-30406) Jobmanager Deployment error without HA metadata should not lead to unrecoverable error

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30406: -- Summary: Jobmanager Deployment error without HA metadata should not lead to unrecoverable error Key: FLINK-30406 URL: https://issues.apache.org/jira/browse/FLINK-30406

[jira] [Created] (FLINK-30405) Add ResourceLifecycleStatus to CommonStatus and printer column

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30405: -- Summary: Add ResourceLifecycleStatus to CommonStatus and printer column Key: FLINK-30405 URL: https://issues.apache.org/jira/browse/FLINK-30405 Project: Flink

[jira] [Created] (FLINK-30404) Do not redeploy taskmanagers on standalone application scaling

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30404: -- Summary: Do not redeploy taskmanagers on standalone application scaling Key: FLINK-30404 URL: https://issues.apache.org/jira/browse/FLINK-30404 Project: Flink

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

2022-12-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29588. -- Resolution: Won't Fix > Add Flink Version and Application Version to Savepoint properties >

[jira] [Closed] (FLINK-29939) Add metrics for Kubernetes Client Response 5xx count and rate

2022-12-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29939. -- Fix Version/s: kubernetes-operator-1.4.0 Resolution: Fixed merged to main

[jira] [Updated] (FLINK-29939) Add metrics for Kubernetes Client Response 5xx count and rate

2022-12-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29939: --- Affects Version/s: (was: kubernetes-operator-1.3.0) > Add metrics for Kubernetes Client

[jira] [Updated] (FLINK-30361) Cluster deleted and created back while updating replicas

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

[jira] [Updated] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

2022-12-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30363: --- Affects Version/s: (was: kubernetes-operator-1.1.0) > Disable HadoppConf and Kerboros Decorator

[jira] [Assigned] (FLINK-30361) Cluster deleted and created back while updating replicas

2022-12-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30361: -- Assignee: SwathiChandrashekar > Cluster deleted and created back while updating replicas >

[jira] [Commented] (FLINK-30361) Cluster deleted and created back while updating replicas

2022-12-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645786#comment-17645786 ] Gyula Fora commented on FLINK-30361: [~Swathi Chandrashekar] do you want to give this issue a try? 

[jira] [Commented] (FLINK-30361) Flink cluster deleted while updating the replicas

2022-12-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645770#comment-17645770 ] Gyula Fora commented on FLINK-30361: We have similar logic in place for standalone applications with

[jira] [Updated] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30306: --- Fix Version/s: (was: kubernetes-operator-1.3.0) > Audit utils can expose potentially sensitive

[jira] [Updated] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30306: --- Issue Type: Improvement (was: Bug) > Audit utils can expose potentially sensitive information >

[jira] [Updated] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30306: --- Fix Version/s: kubernetes-operator-1.3.0 > Audit utils can expose potentially sensitive information

[jira] [Updated] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30313: --- Priority: Critical (was: Major) > Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but

[jira] [Updated] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30313: --- Fix Version/s: kubernetes-operator-1.3.0 > Flink Kubernetes Operator seems to rely on 1.15 k8s HA

[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644306#comment-17644306 ] Gyula Fora commented on FLINK-30313: [~mapohl] coild you reproduce this locally? maybe you could do

[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644302#comment-17644302 ] Gyula Fora commented on FLINK-30313: At this point operator should not contain any 1.16 dependencies

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644052#comment-17644052 ] Gyula Fora commented on FLINK-30305: That’s correct , the savepoint from the status is only

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643922#comment-17643922 ] Gyula Fora commented on FLINK-30305: i think you are missing the crucial problem here. You have to

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643615#comment-17643615 ] Gyula Fora commented on FLINK-30305: When you execute stop with savepoint operation in Flink, the

[jira] [Closed] (FLINK-30266) Recovery reconciliation loop fails if no checkpoint has been created yet

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30266. -- Resolution: Fixed Merged to main 72ad3639e60fbf27dd408dabbe69f46d69ff52f9 > Recovery reconciliation

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643573#comment-17643573 ] Gyula Fora commented on FLINK-30305: I recommend checking the getAvailableUpgradeMode method of the

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643495#comment-17643495 ] Gyula Fora commented on FLINK-30305: We haven’t yet found a completely reliable way to detect if the

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643489#comment-17643489 ] Gyula Fora commented on FLINK-30305: You could try doing the same flow but originally using the

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643488#comment-17643488 ] Gyula Fora commented on FLINK-30305: I think there are a mix of things happening here. And it may

[jira] [Commented] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643479#comment-17643479 ] Gyula Fora commented on FLINK-30306: Why would the spec contain injected sensitive info? Wouldn’t

[jira] [Commented] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643478#comment-17643478 ] Gyula Fora commented on FLINK-30306: Cc @morhidi  > Audit utils can expose potentially sensitive

[jira] [Closed] (FLINK-30186) Bump Flink version to 1.15.3

2022-12-04 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30186. -- Resolution: Fixed Merged to main 3c5ec6cd86de61752c708eba385646a7c1164880 > Bump Flink version to

[jira] [Updated] (FLINK-30268) HA metadata and other cluster submission related errors should not throw DeploymentFailedException

2022-12-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30268: --- Issue Type: Bug (was: Improvement) > HA metadata and other cluster submission related errors

[jira] [Created] (FLINK-30268) HA metadata and other cluster submission related errors should not throw DeploymentFailedException

2022-12-01 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30268: -- Summary: HA metadata and other cluster submission related errors should not throw DeploymentFailedException Key: FLINK-30268 URL: https://issues.apache.org/jira/browse/FLINK-30268

[jira] [Updated] (FLINK-30266) Recovery reconciliation loop fails if no checkpoint has been created yet

2022-12-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30266: --- Priority: Blocker (was: Major) > Recovery reconciliation loop fails if no checkpoint has been

[jira] [Updated] (FLINK-30266) Recovery reconciliation loop fails if no checkpoint has been created yet

2022-12-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30266: --- Fix Version/s: kubernetes-operator-1.3.0 > Recovery reconciliation loop fails if no checkpoint has

[jira] [Updated] (FLINK-29847) Store/cache JarUploadResponseBody

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

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

2022-11-30 Thread Gyula Fora (Jira)
[ 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.4.0 (was: kubernetes-operator-1.3.0) >

[jira] [Commented] (FLINK-30244) When task using udf/udtf with jni, on k8s session the old TM will shut down and create new TM or the task will fail

2022-11-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641162#comment-17641162 ] Gyula Fora commented on FLINK-30244: When using the Native (active) kubernetes integration. Session

[jira] [Commented] (FLINK-30244) When task using udf/udtf with jni, flink on k8s session the old

2022-11-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641089#comment-17641089 ] Gyula Fora commented on FLINK-30244: Could you please provide a proper title and description for the

[jira] [Closed] (FLINK-30090) Support timespan for TimerGauges

2022-11-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30090. -- Fix Version/s: 1.17.0 Resolution: Fixed merged to master

[jira] [Closed] (FLINK-30214) The resource is not enough

2022-11-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30214. -- Fix Version/s: 1.17.0 Assignee: Rui Fan Resolution: Fixed merged to master

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

2022-11-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reopened FLINK-29109: > Checkpoint path conflict with stateless upgrade mode >

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

2022-11-28 Thread Gyula Fora (Jira)
[ 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: (was: kubernetes-operator-1.3.0) > Simplify controller flow by introducing

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

2022-11-28 Thread Gyula Fora (Jira)
[ 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.4.0 > Support env replacement in flink-kubernetes-operator CR

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

2022-11-28 Thread Gyula Fora (Jira)
[ 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: (was: kubernetes-operator-1.3.0) > Support env replacement in

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

2022-11-28 Thread Gyula Fora (Jira)
[ 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: (was: kubernetes-operator-1.3.0) > Add metrics for FlinkService >

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

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28408. -- Resolution: Won't Do > FAQ / best practices page for Kubernetes Operator >

[jira] [Updated] (FLINK-27037) Publish Javadocs for Kubernetes Operator

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27037: --- Fix Version/s: kubernetes-operator-1.3.0 > Publish Javadocs for Kubernetes Operator >

[jira] [Closed] (FLINK-27190) Revisit error handling in main reconcile() loop

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27190. -- Resolution: Won't Fix Let's open new tickets for concrete tasks here if we see any > Revisit error

[jira] [Assigned] (FLINK-27037) Publish Javadocs for Kubernetes Operator

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27037: -- Assignee: Márton Balassi > Publish Javadocs for Kubernetes Operator >

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

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28875: -- Assignee: (was: Aitozi) > Add FlinkSessionJobControllerTest >

[jira] [Commented] (FLINK-29110) Support to mount a dynamically-created pvc for JM and TM in standalone mode with StatefulSet.

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639908#comment-17639908 ] Gyula Fora commented on FLINK-29110: [~kevin_123]  are you still working on this? > Support to

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

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29199. -- Resolution: Won't Do We should revisit this if we see a need in the future > Support blue-green

[jira] [Commented] (FLINK-29974) Session jobs in FINISHED/FAILED state cannot be suspended

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639906#comment-17639906 ] Gyula Fora commented on FLINK-29974: cc [~gsomogyi]  Could you please help [~sriramgr] finish this?

[jira] [Updated] (FLINK-30046) Cannot use digest in Helm chart to reference image

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30046: --- Fix Version/s: kubernetes-operator-1.3.0 > Cannot use digest in Helm chart to reference image >

[jira] [Updated] (FLINK-29974) Session jobs in FINISHED/FAILED state cannot be suspended

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29974: --- Fix Version/s: kubernetes-operator-1.3.0 > Session jobs in FINISHED/FAILED state cannot be

[jira] [Assigned] (FLINK-30046) Cannot use digest in Helm chart to reference image

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30046: -- Assignee: Márton Balassi > Cannot use digest in Helm chart to reference image >

[jira] [Assigned] (FLINK-30119) (Flink Kubernetes Operator should store last savepoint in the SavepointInfo.lastSavepoint field whether it is completed or pending

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30119: -- Assignee: Clara Xiong > (Flink Kubernetes Operator should store last savepoint in the >

[jira] [Updated] (FLINK-30115) Include log4j-layout-template-json jar in the default operator image

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30115: --- Priority: Minor (was: Major) > Include log4j-layout-template-json jar in the default operator

[jira] [Assigned] (FLINK-30154) flinkConfiguration in SessionJob is not accepted

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30154: -- Assignee: Gabor Somogyi > flinkConfiguration in SessionJob is not accepted >

[jira] [Assigned] (FLINK-30199) Add a script to run Kubernetes Operator e2e tests manually

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30199: -- Assignee: Peter Vary > Add a script to run Kubernetes Operator e2e tests manually >

[jira] [Assigned] (FLINK-30216) Address tabs/spaces in checkstyle/spotless

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30216: -- Assignee: Daren Wong (was: a) > Address tabs/spaces in checkstyle/spotless >

[jira] [Assigned] (FLINK-30216) Address tabs/spaces in checkstyle/spotless

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30216: -- Assignee: a > Address tabs/spaces in checkstyle/spotless >

[jira] [Assigned] (FLINK-30222) Suspended a job in last-state mode bug

2022-11-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30222: -- Assignee: Peter Vary > Suspended a job in last-state mode bug >

[jira] [Updated] (FLINK-30222) Suspended a job in last-state mode bug

2022-11-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30222: --- Priority: Blocker (was: Major) > Suspended a job in last-state mode bug >

[jira] [Updated] (FLINK-30222) Suspended a job in last-state mode bug

2022-11-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30222: --- Fix Version/s: kubernetes-operator-1.3.0 > Suspended a job in last-state mode bug >

[jira] [Commented] (FLINK-30222) Suspended a job in last-state mode bug

2022-11-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639640#comment-17639640 ] Gyula Fora commented on FLINK-30222: Good catch! Would you like to work on this ticket? The current

[jira] [Commented] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

2022-11-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638774#comment-17638774 ] Gyula Fora commented on FLINK-30213: The same issue already existed Flink with the reactive scaling

[jira] [Updated] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

2022-11-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30213: --- Attachment: image-2022-11-25-21-58-48-968.png > The edge is wrong when the vertex parallelism is

[jira] [Commented] (FLINK-30214) The resource is not enough

2022-11-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638602#comment-17638602 ] Gyula Fora commented on FLINK-30214: Hi [~fanrui], Thanks for jumping on this and testing it.

<    4   5   6   7   8   9   10   11   12   13   >