Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc]

2025-05-06 Thread via GitHub
lhh-yeah commented on PR #3916: URL: https://github.com/apache/flink-cdc/pull/3916#issuecomment-2857321869 When is it scheduled to be released? -- 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

[jira] [Created] (FLINK-37766) FlinkSessionJob deletion blocked by finalizer when Flink job already terminal/missing due to HA desync

2025-05-06 Thread Kartikey Pant (Jira)
Kartikey Pant created FLINK-37766: - Summary: FlinkSessionJob deletion blocked by finalizer when Flink job already terminal/missing due to HA desync Key: FLINK-37766 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-37765) Idea import duplicate modules error.

2025-05-06 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-37765: --- Summary: Idea import duplicate modules error. Key: FLINK-37765 URL: https://issues.apache.org/jira/browse/FLINK-37765 Project: Flink Issue Type: Improvement

Re: [PR] [BP-1.20] [FLINK-35657][runtime-web] use parseFloat for metric value [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25047: URL: https://github.com/apache/flink/pull/25047#issuecomment-2857255336 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-36008][Documentation] Script and guidance to preview connector docs contributions [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25181: URL: https://github.com/apache/flink/pull/25181#issuecomment-2857256343 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix] [docs/test] Fix docs and testcases of Json format [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25188: URL: https://github.com/apache/flink/pull/25188#issuecomment-2857256488 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-36029] Add @Nullable Annotation to ValueState's Value Method Return Type [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25187: URL: https://github.com/apache/flink/pull/25187#issuecomment-2857256417 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix] Fix npm issue in document Build [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25147: [hotfix] Fix npm issue in document Build URL: https://github.com/apache/flink/pull/25147 -- 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

Re: [PR] [FLINK-35902][ui] WebUI Metrics RangeError on huge parallelism [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25123: [FLINK-35902][ui] WebUI Metrics RangeError on huge parallelism URL: https://github.com/apache/flink/pull/25123 -- 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

Re: [PR] [FLINK-36029] Add @Nullable Annotation to ValueState's Value Method Return Type [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25187: [FLINK-36029] Add @Nullable Annotation to ValueState's Value Method Return Type URL: https://github.com/apache/flink/pull/25187 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

Re: [PR] [hotfix] Fix npm issue in document Build [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25147: URL: https://github.com/apache/flink/pull/25147#issuecomment-2857256255 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-35560][Table SQL/Gateway] Support custom query operation validator for sql gateway [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25092: URL: https://github.com/apache/flink/pull/25092#issuecomment-2857255703 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [Fix][javadocs] Fix typo in DataStreamSource [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25124: URL: https://github.com/apache/flink/pull/25124#issuecomment-2857256079 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-35897][Checkpoint] Cleanup completed resource when checkpoint is canceled [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25120: URL: https://github.com/apache/flink/pull/25120#issuecomment-2857255952 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] Update SimpleStringSchema.java [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25096: Update SimpleStringSchema.java URL: https://github.com/apache/flink/pull/25096 -- 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. T

Re: [PR] [FLINK-12450] Add leftshift, rightshift functions support in Table API and SQL [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25053: URL: https://github.com/apache/flink/pull/25053#issuecomment-2857255395 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-35560][Table SQL/Gateway] Support custom query operation validator for sql gateway [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25092: [FLINK-35560][Table SQL/Gateway] Support custom query operation validator for sql gateway URL: https://github.com/apache/flink/pull/25092 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] [FLINK-26232][tests][JUnit5 migration] Module:flink-avro [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25087: [FLINK-26232][tests][JUnit5 migration] Module:flink-avro URL: https://github.com/apache/flink/pull/25087 -- 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

Re: [PR] [BP-1.19] [FLINK-35657][runtime-web] use parseFloat for metric value [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25046: URL: https://github.com/apache/flink/pull/25046#issuecomment-2857255270 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [BP-1.20] [FLINK-35657][runtime-web] use parseFloat for metric value [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25047: [BP-1.20] [FLINK-35657][runtime-web] use parseFloat for metric value URL: https://github.com/apache/flink/pull/25047 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [BP-1.19] [FLINK-35657][runtime-web] use parseFloat for metric value [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25046: [BP-1.19] [FLINK-35657][runtime-web] use parseFloat for metric value URL: https://github.com/apache/flink/pull/25046 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [hotfix] [docs/test] Fix docs and testcases of Json format [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25188: [hotfix] [docs/test] Fix docs and testcases of Json format URL: https://github.com/apache/flink/pull/25188 -- 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 g

Re: [PR] [FLINK-35925] remove hive connector from main repo [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25129: URL: https://github.com/apache/flink/pull/25129#issuecomment-2857256199 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix][doc] missing "STATISTICS" sql reserved keyword in zh doc [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25041: URL: https://github.com/apache/flink/pull/25041#issuecomment-2857255206 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-36008][Documentation] Script and guidance to preview connector docs contributions [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25181: [FLINK-36008][Documentation] Script and guidance to preview connector docs contributions URL: https://github.com/apache/flink/pull/25181 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

Re: [PR] [FLINK-35925] remove hive connector from main repo [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25129: [FLINK-35925] remove hive connector from main repo URL: https://github.com/apache/flink/pull/25129 -- 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

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25018: [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 URL: https://github.com/apache/flink/pull/25018 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] [Fix][javadocs] Fix typo in DataStreamSource [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25124: [Fix][javadocs] Fix typo in DataStreamSource URL: https://github.com/apache/flink/pull/25124 -- 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 speci

Re: [PR] [FLINK-35628][docs] Provide a Chinese translation of datagen.md [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25128: [FLINK-35628][docs] Provide a Chinese translation of datagen.md URL: https://github.com/apache/flink/pull/25128 -- 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

Re: [PR] [FLINK-35628][docs] Provide a Chinese translation of datagen.md [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25128: URL: https://github.com/apache/flink/pull/25128#issuecomment-2857256127 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-35902][ui] WebUI Metrics RangeError on huge parallelism [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25123: URL: https://github.com/apache/flink/pull/25123#issuecomment-2857256015 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-35864][table] Add CONV function [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25109: [FLINK-35864][table] Add CONV function URL: https://github.com/apache/flink/pull/25109 -- 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 co

Re: [PR] [FLINK-35897][Checkpoint] Cleanup completed resource when checkpoint is canceled [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25120: [FLINK-35897][Checkpoint] Cleanup completed resource when checkpoint is canceled URL: https://github.com/apache/flink/pull/25120 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [FLINK-35864][table] Add CONV function [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25109: URL: https://github.com/apache/flink/pull/25109#issuecomment-2857255894 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] Update SimpleStringSchema.java [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25096: URL: https://github.com/apache/flink/pull/25096#issuecomment-2857255819 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26232][tests][JUnit5 migration] Module:flink-avro [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25087: URL: https://github.com/apache/flink/pull/25087#issuecomment-2857255591 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-35797] DRAFT of work for FLIP-456. [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25063: [FLINK-35797] DRAFT of work for FLIP-456. URL: https://github.com/apache/flink/pull/25063 -- 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

Re: [PR] [FLINK-35797] DRAFT of work for FLIP-456. [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25063: URL: https://github.com/apache/flink/pull/25063#issuecomment-2857255464 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-12450] Add leftshift, rightshift functions support in Table API and SQL [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25053: [FLINK-12450] Add leftshift, rightshift functions support in Table API and SQL URL: https://github.com/apache/flink/pull/25053 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] [hotfix][doc] missing "STATISTICS" sql reserved keyword in zh doc [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25041: [hotfix][doc] missing "STATISTICS" sql reserved keyword in zh doc URL: https://github.com/apache/flink/pull/25041 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]

2025-05-06 Thread via GitHub
github-actions[bot] closed pull request #25027: [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed URL: https://github.com/apache/flink/pull/25027 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25027: URL: https://github.com/apache/flink/pull/25027#issuecomment-2857255146 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink]

2025-05-06 Thread via GitHub
github-actions[bot] commented on PR #25018: URL: https://github.com/apache/flink/pull/25018#issuecomment-2857255091 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

[jira] [Comment Edited] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

2025-05-06 Thread Junrui Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949900#comment-17949900 ] Junrui Lee edited comment on FLINK-37761 at 5/7/25 5:55 AM:

[jira] [Commented] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

2025-05-06 Thread Junrui Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949900#comment-17949900 ] Junrui Lee commented on FLINK-37761: [~lsy] ** I will try to replicate it locally fi

[jira] [Commented] (FLINK-34071) Deadlock in AWS Kinesis Data Streams AsyncSink connector

2025-05-06 Thread Nagesh Honnalli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949897#comment-17949897 ] Nagesh Honnalli commented on FLINK-34071: - Can you please assign this to me? I h

Re: [PR] [FLINK-33721][core] Extend BashJavaUtils to support reading and writing standard yaml file. [flink]

2025-05-06 Thread via GitHub
melin commented on PR #24091: URL: https://github.com/apache/flink/pull/24091#issuecomment-2857087003 flink on k8s,An error occurred when starting the task: /opt/flink/bin/config-parser-utils.sh: line 45: /opt/flink/conf/config.yaml: Read-only file system @JunRuiLee -- This is

[jira] [Resolved] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang resolved FLINK-37702. -- Resolution: Fixed Merged into master via 3e8f34dac5fcec5947633e0a48cd34a9c5fb7333 > The pytho

[jira] [Assigned] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-37702: Assignee: Mika Naylor > The python cron hadoop pipeline failed of azure ci >

Re: [PR] [FLINK-37702][ci] Ensure Python setup/headers for Python tests [flink]

2025-05-06 Thread via GitHub
HuangXingBo merged PR #26529: URL: https://github.com/apache/flink/pull/26529 -- 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: issues-unsubscr...@flink.a

Re: [PR] [FLINK-36932][metrics] Added resource-level metrics for different states/statuses [flink-kubernetes-operator]

2025-05-06 Thread via GitHub
blaskovicz commented on PR #926: URL: https://github.com/apache/flink-kubernetes-operator/pull/926#issuecomment-2856469788 @gyfora any updates here? -- 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

[jira] [Commented] (FLINK-36932) Add resource-level metrics for different status/states to flink-kubernetes-operator

2025-05-06 Thread Zach (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949850#comment-17949850 ] Zach commented on FLINK-36932: -- This would be an excellent enhancement. Any updates here te

Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator]

2025-05-06 Thread via GitHub
morhidi commented on PR #978: URL: https://github.com/apache/flink-kubernetes-operator/pull/978#issuecomment-2855917858 > > I like this draft a lot. > > @gyfora can you take a quick look as well, or would you prefer this to be fully ready before you take a > > > I like this draft

Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator]

2025-05-06 Thread via GitHub
gyfora commented on PR #978: URL: https://github.com/apache/flink-kubernetes-operator/pull/978#issuecomment-2855871559 > I like this draft a lot. > > @gyfora can you take a quick look as well, or would you prefer this to be fully ready before you take a > I like this draft a l

Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator]

2025-05-06 Thread via GitHub
rmetzger commented on code in PR #978: URL: https://github.com/apache/flink-kubernetes-operator/pull/978#discussion_r2076080196 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -299,9 +303,92

Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue

2025-05-06 Thread via GitHub
saholman commented on PR #195: URL: https://github.com/apache/flink-connector-aws/pull/195#issuecomment-2855815394 @hlteoh37 or @darenwkt could you create a new tag that includes this fix? The latest version in Maven still has this bug. -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread Mika Naylor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949827#comment-17949827 ] Mika Naylor commented on FLINK-37702: - [~lsy] I opened a PR to address this - it tur

[jira] [Updated] (FLINK-37764) Add support for configurable custom TrustManagerFactory in SSLUtils

2025-05-06 Thread Purshotam Shah (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Purshotam Shah updated FLINK-37764: --- Description: *Background* Currently, SSLUtils only supports the built-in FingerprintTrustMan

Re: [PR] [FLINK-xxx][1/N] introduce MODEL keyword for model as argument [flink]

2025-05-06 Thread via GitHub
flinkbot commented on PR #26530: URL: https://github.com/apache/flink/pull/26530#issuecomment-284491 ## CI report: * e91f4c35f56bb56e7ef9c66182cc8cda2fde3acd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-xxx][1/N] introduce MODEL keyword for model as argument in fun… [flink]

2025-05-06 Thread via GitHub
lihaosky opened a new pull request, #26530: URL: https://github.com/apache/flink/pull/26530 …ction ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-trans

[jira] [Updated] (FLINK-37764) Add support for configurable custom TrustManagerFactory in SSLUtils

2025-05-06 Thread Purshotam Shah (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Purshotam Shah updated FLINK-37764: --- Description: Thought for a couple of seconds *Jira Description* *Background* Currently, SS

[jira] [Updated] (FLINK-37764) Add support for configurable custom TrustManagerFactory in SSLUtils

2025-05-06 Thread Purshotam Shah (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Purshotam Shah updated FLINK-37764: --- Description: Thought for a couple of seconds *Jira Description* *Background* Currently, SS

[jira] [Created] (FLINK-37764) Add support for configurable custom TrustManagerFactory in SSLUtils

2025-05-06 Thread Purshotam Shah (Jira)
Purshotam Shah created FLINK-37764: -- Summary: Add support for configurable custom TrustManagerFactory in SSLUtils Key: FLINK-37764 URL: https://issues.apache.org/jira/browse/FLINK-37764 Project: Flin

[PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator]

2025-05-06 Thread via GitHub
vsantwana opened a new pull request, #978: URL: https://github.com/apache/flink-kubernetes-operator/pull/978 ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the `FlinkDeployment` cu

Re: [PR] [FLINK-30571] Estimate scalability coefficient from past scaling history using linear regression [flink-kubernetes-operator]

2025-05-06 Thread via GitHub
mxm merged PR #966: URL: https://github.com/apache/flink-kubernetes-operator/pull/966 -- 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: issues-unsubscr...

[jira] [Closed] (FLINK-37662) Allow configuration of init/side car containers

2025-05-06 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed FLINK-37662. Fix Version/s: kubernetes-operator-1.12.0 Resolution: Implemented > Allow configuration of

Re: [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator]

2025-05-06 Thread via GitHub
tweise merged PR #977: URL: https://github.com/apache/flink-kubernetes-operator/pull/977 -- 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: issues-unsubscr

Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue

2025-05-06 Thread via GitHub
saholman commented on PR #195: URL: https://github.com/apache/flink-connector-aws/pull/195#issuecomment-2854955599 When will a new released version of flink-connector-aws be tagged that includes this fix? -- This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Commented] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP

2025-05-06 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949748#comment-17949748 ] Martijn Visser commented on FLINK-37753: [~davidradl] I think it needs a discuss

Re: [PR] [FLINK-37632][table] Add changelog support to PTFs [flink]

2025-05-06 Thread via GitHub
dawidwys commented on code in PR #26527: URL: https://github.com/apache/flink/pull/26527#discussion_r2075417209 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/CallContext.java: ## @@ -67,14 +69,27 @@ public interface CallContext { /**

Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink]

2025-05-06 Thread via GitHub
gaborgsomogyi commented on code in PR #26521: URL: https://github.com/apache/flink/pull/26521#discussion_r2075494144 ## flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointConnectorOptions.java: ## @@ -132,8 +133,27 @@ public enum State

[jira] [Created] (FLINK-37763) Support multiple tables with set semantics

2025-05-06 Thread Timo Walther (Jira)
Timo Walther created FLINK-37763: Summary: Support multiple tables with set semantics Key: FLINK-37763 URL: https://issues.apache.org/jira/browse/FLINK-37763 Project: Flink Issue Type: Sub-ta

Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink]

2025-05-06 Thread via GitHub
gaborgsomogyi commented on code in PR #26521: URL: https://github.com/apache/flink/pull/26521#discussion_r2075494144 ## flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointConnectorOptions.java: ## @@ -132,8 +133,27 @@ public enum State

[jira] [Updated] (FLINK-37762) No Infomation in Overview at Flink CDC 3.4

2025-05-06 Thread 911432 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 911432 updated FLINK-37762: --- Summary: No Infomation in Overview at Flink CDC 3.4 (was: No Infomation) > No Infomation in Overview at Fli

[jira] [Created] (FLINK-37762) No Infomation

2025-05-06 Thread 911432 (Jira)
911432 created FLINK-37762: -- Summary: No Infomation Key: FLINK-37762 URL: https://issues.apache.org/jira/browse/FLINK-37762 Project: Flink Issue Type: Improvement Components: Flink CDC

Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink]

2025-05-06 Thread via GitHub
gaborgsomogyi commented on code in PR #26521: URL: https://github.com/apache/flink/pull/26521#discussion_r2075471691 ## flink-libraries/flink-state-processing-api/src/test/java/com/example/state/writer/job/schema/avro/AvroRecord.java: ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink]

2025-05-06 Thread via GitHub
gaborgsomogyi commented on PR #26521: URL: https://github.com/apache/flink/pull/26521#issuecomment-2854490649 > @gaborgsomogyi I was reading the flip an was expecting a generic mechanism, but the Pr is Avro specific. Did I misunderstand ? I think it would be helpful to have Avro in the titl

Re: [PR] [FLINK-37702][ci] Ensure Python setup/headers for Python tests [flink]

2025-05-06 Thread via GitHub
flinkbot commented on PR #26529: URL: https://github.com/apache/flink/pull/26529#issuecomment-2854472998 ## CI report: * e34aa84441c372b3ae4e5497018ba60d192f9134 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37702: --- Labels: pull-request-available (was: ) > The python cron hadoop pipeline failed of azure ci

[PR] [FLINK-37702][ci] Ensure Python setup/headers for Python tests [flink]

2025-05-06 Thread via GitHub
autophagy opened a new pull request, #26529: URL: https://github.com/apache/flink/pull/26529 ## What is the purpose of the change This change ensures that Python installation (Python.h headers, etc) are available during tests, regardless of whether the underlying CI machine has Pytho

[jira] [Commented] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949717#comment-17949717 ] dalongliu commented on FLINK-37761: --- [~JunRuiLi] Can you help check this case? > Batc

[jira] [Commented] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949715#comment-17949715 ] dalongliu commented on FLINK-37761: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

2025-05-06 Thread dalongliu (Jira)
dalongliu created FLINK-37761: - Summary: BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline Key: FLINK-37761 URL: https://issues.ap

[jira] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37703 ] dalongliu deleted comment on FLINK-37703: --- was (Author: lsy): This case has not reappeared and appears to be just an occasional unstable case, closing it > The testRecoverFromIntermWithoutAdd

[jira] [Commented] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949714#comment-17949714 ] dalongliu commented on FLINK-37703: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Reopened] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reopened FLINK-37703: --- > The testRecoverFromIntermWithoutAdditionalState test failed of azure cron > connector pipeline > ---

[jira] [Closed] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu closed FLINK-37703. - Resolution: Fixed > The testRecoverFromIntermWithoutAdditionalState test failed of azure cron > connect

[jira] [Commented] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949713#comment-17949713 ] dalongliu commented on FLINK-37703: --- This case has not reappeared and appears to be ju

[jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949712#comment-17949712 ] dalongliu commented on FLINK-37701: --- After checking the release-2.0 branch, I found th

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread Mika Naylor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949710#comment-17949710 ] Mika Naylor commented on FLINK-37702: - [~lsy] Yep, can do > The python cron hadoop

[jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949706#comment-17949706 ] dalongliu commented on FLINK-37701: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949705#comment-17949705 ] dalongliu commented on FLINK-37701: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949704#comment-17949704 ] dalongliu commented on FLINK-37702: --- [~autophagian] Can you also help take a look? >

[jira] [Comment Edited] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949697#comment-17949697 ] dalongliu edited comment on FLINK-37702 at 5/6/25 12:06 PM:

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949697#comment-17949697 ] dalongliu commented on FLINK-37702: --- The failed Python case first occurred is 14/02/25

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949694#comment-17949694 ] dalongliu commented on FLINK-37702: --- [~dianfu] Can you help confirm this is a blocker?

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949693#comment-17949693 ] dalongliu commented on FLINK-37702: --- I checked the CI pipeline for the last 5 days on

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949689#comment-17949689 ] dalongliu commented on FLINK-37702: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949686#comment-17949686 ] dalongliu commented on FLINK-37702: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci

2025-05-06 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949685#comment-17949685 ] dalongliu commented on FLINK-37702: --- https://dev.azure.com/apache-flink/apache-flink/_

  1   2   >