[jira] [Created] (FLINK-30538) Improve error handling of stop job operation

Paul Lin created FLINK-30538: Summary: Improve error handling of stop job operation Key: FLINK-30538 URL: https://issues.apache.org/jira/browse/FLINK-30538 Project: Flink Issue Type: Sub-task

[GitHub] [flink] ramkrish86 commented on a diff in pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

ramkrish86 commented on code in PR #21508: URL: https://github.com/apache/flink/pull/21508#discussion_r1059863005 ## flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureBlobFsRecoverableDataOutputStream.java: ## @@ -0,0 +1,299 @@ +/* + *

[GitHub] [flink] ramkrish86 commented on a diff in pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

ramkrish86 commented on code in PR #21508: URL: https://github.com/apache/flink/pull/21508#discussion_r1059862791 ## flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureBlobFsRecoverableDataOutputStream.java: ## @@ -0,0 +1,312 @@ +/* + *

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 3:28 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 3:27 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 3:19 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 3:13 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:53 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:45 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:44 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:43 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:41 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:38 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:28 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:28 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:27 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:23 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:22 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:21 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:21 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:20 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:20 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:19 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:19 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:12 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:12 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:02 AM: --- [~gyfora] [~thw]

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:01 AM: --- [~gyfora] [~thw]

[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=17653483#comment-17653483 ] Jiale Tan commented on FLINK-29634: --- [~gyfora] [~thw] Thanks for the guidance! I am trying to bump

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

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653483#comment-17653483 ] Jiale Tan edited comment on FLINK-29634 at 1/2/23 2:00 AM: --- [~gyfora] [~thw]

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #493: [FLINK-30464] Exclude metrics during stabilization and ensure a full metric window

gyfora commented on code in PR #493: URL: https://github.com/apache/flink-kubernetes-operator/pull/493#discussion_r1059789401 ## docs/layouts/shortcodes/generated/auto_scaler_configuration.html: ## @@ -21,10 +21,16 @@ Enable job autoscaler module.

[jira] [Commented] (FLINK-30231) Update to Fabric8 Kubernetes Client to a version that has automatic renewal of service account tokens

[ https://issues.apache.org/jira/browse/FLINK-30231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653452#comment-17653452 ] Martijn Visser commented on FLINK-30231: [~liadsh] Can you open a PR for this upgrade? > Update

[jira] [Commented] (FLINK-30537) Add support for OpenSearch 2.3

[ https://issues.apache.org/jira/browse/FLINK-30537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653450#comment-17653450 ] Andriy Redko commented on FLINK-30537: -- The current Opensearch connector supports both 1.3.x and

[jira] [Assigned] (FLINK-30329) flink-kubernetes-operator helm chart does not work with dynamic config because of use of volumeMount subPath

[ https://issues.apache.org/jira/browse/FLINK-30329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30329: -- Assignee: Andrew Otto > flink-kubernetes-operator helm chart does not work with dynamic

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

[ https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30408: -- Assignee: Gyula Fora > Add unit test for HA metadata check logic >

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

[ https://issues.apache.org/jira/browse/FLINK-30406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30406: --- Issue Type: Bug (was: Improvement) > Jobmanager Deployment error without HA metadata should not

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

[ 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: kubernetes-operator-1.3.1 > Cluster deleted and created back while updating replicas

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

[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653432#comment-17653432 ] Gyula Fora commented on FLINK-30361: release-1.3 7da3cdd6ec4bfd20f24d27dc70df1c40abe6a341 > Cluster

[jira] [Closed] (FLINK-30528) Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing

[ https://issues.apache.org/jira/browse/FLINK-30528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30528. -- Fix Version/s: kubernetes-operator-1.4.0 kubernetes-operator-1.3.1

[jira] [Closed] (FLINK-30527) Last-state suspend followed by flinkVersion change may lead to state loss

[ https://issues.apache.org/jira/browse/FLINK-30527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30527. -- Fix Version/s: kubernetes-operator-1.4.0 kubernetes-operator-1.3.1

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #498: Backport remaining fixes for 1.3.1

gyfora merged PR #498: URL: https://github.com/apache/flink-kubernetes-operator/pull/498 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #497: [FLINK-30528] Reconcile other changes if upgrade is not available

gyfora merged PR #497: URL: https://github.com/apache/flink-kubernetes-operator/pull/497 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #496: [FLINK-30527] Validate flinkVersion change for suspended jobs

gyfora merged PR #496: URL: https://github.com/apache/flink-kubernetes-operator/pull/496 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-30231) Update to Fabric8 Kubernetes Client to a version that has automatic renewal of service account tokens

[ https://issues.apache.org/jira/browse/FLINK-30231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653425#comment-17653425 ] liad shachoach commented on FLINK-30231: Hey, We need this feature too. AWS are removing EKS

[GitHub] [flink] LadyForest commented on pull request #21571: [FLINK-22317][table] Support DROP column/constraint/watermark for ALTER TABLE statement

LadyForest commented on PR #21571: URL: https://github.com/apache/flink/pull/21571#issuecomment-1368446229 > Thanks for the update! I add a commit to improve some codes. Please take a look at the last commit when you are free. Thanks for the improvement, LGTM  -- This is an

[jira] [Created] (FLINK-30537) Add support for OpenSearch 2.3

Martijn Visser created FLINK-30537: -- Summary: Add support for OpenSearch 2.3 Key: FLINK-30537 URL: https://issues.apache.org/jira/browse/FLINK-30537 Project: Flink Issue Type: Improvement

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #498: Backport remaining fixes for 1.3.1

gyfora opened a new pull request, #498: URL: https://github.com/apache/flink-kubernetes-operator/pull/498 Backport: - 6e597f76 [FLINK-30527] Validate flinkVersion change for suspended jobs - 0d2595ac [FLINK-30528] Reconcile other changes if upgrade is not available - abc8e6b7