Re: [DISCUSS] State Schema Evolution for RowData

2025-07-17 Thread Weiqing Yang
Hi Zakelly and Hangxiang, Just checking in - do you have any concerns or feedback? If there are no further objections from anyone, I’ll mark the FLIP as ready for voting. Best, Weiqing On Sun, Jul 6, 2025 at 11:46 PM Weiqing Yang wrote: > Hi Hangxiang, Zakelly, > > Thank you for the careful

[jira] [Created] (FLINK-38119) [Unstable test]IcebergWriterTest.testWriteWithAllSupportedTypes:344

2025-07-17 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-38119: -- Summary: [Unstable test]IcebergWriterTest.testWriteWithAllSupportedTypes:344 Key: FLINK-38119 URL: https://issues.apache.org/jira/browse/FLINK-38119 Project: Flink

[DISCUSS] FLIP-535:Introduce RateLimiter to Source

2025-07-17 Thread Zexian WU
Hi everyone, I would like to start a discussion on a new Flink Improvement Proposal (FLIP), FLIP-535: Introduce RateLimiter to Source. The full proposal can be found on the wiki: https://cwiki.apache.org/confluence/display/FLINK/FLIP-535%3A+Introduce+RateLimiter+to+Source Motivation In many produ

[jira] [Created] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode

2025-07-17 Thread shilei-ly (Jira)
shilei-ly created FLINK-38118: - Summary: The execution.attached=true parameter does not take effect in application mode Key: FLINK-38118 URL: https://issues.apache.org/jira/browse/FLINK-38118 Project: Fli

Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API

2025-07-17 Thread Austin Cawley-Edwards
Hey all, Thanks for the nice flip all! I’m just reading through – had one question on the ALTER CONNECTION implementation flow. Would it make sense for the WritableSecretStore to expose a method for updating a secret by ID, so it can be done atomically? Else, would we need to call delete and creat

[jira] [Created] (FLINK-38117) Add anonymous ContextResolvedModel

2025-07-17 Thread Hao Li (Jira)
Hao Li created FLINK-38117: -- Summary: Add anonymous ContextResolvedModel Key: FLINK-38117 URL: https://issues.apache.org/jira/browse/FLINK-38117 Project: Flink Issue Type: Sub-task Repor

[jira] [Created] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error

2025-07-17 Thread David Ballano (Jira)
David Ballano created FLINK-38116: - Summary: Flink kubernetes operator RequestWatchProgress Error Key: FLINK-38116 URL: https://issues.apache.org/jira/browse/FLINK-38116 Project: Flink Issue

Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API

2025-07-17 Thread Ryan van Huuksloot
Hi Mayank, Thanks for updating the FLIP. Overall it looks good to me. One question I had related to how someone could choose the SecretStore they want to use if they use something like the SQL Gateway as the entrypoint on top of a remote Session cluster. I don't see an explicit way to set the Sec

[jira] [Created] (FLINK-38115) Synchronous the Python JDBC connector with the Java implementation

2025-07-17 Thread Dian Fu (Jira)
Dian Fu created FLINK-38115: --- Summary: Synchronous the Python JDBC connector with the Java implementation Key: FLINK-38115 URL: https://issues.apache.org/jira/browse/FLINK-38115 Project: Flink Iss

[jira] [Created] (FLINK-38114) Allow offloading of task restore

2025-07-17 Thread Aleksandr Iushmanov (Jira)
Aleksandr Iushmanov created FLINK-38114: --- Summary: Allow offloading of task restore Key: FLINK-38114 URL: https://issues.apache.org/jira/browse/FLINK-38114 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy

2025-07-17 Thread Aleksandr Iushmanov (Jira)
Aleksandr Iushmanov created FLINK-38113: --- Summary: Rethrow fatal or OOM errors from Execution.deploy Key: FLINK-38113 URL: https://issues.apache.org/jira/browse/FLINK-38113 Project: Flink

[jira] [Created] (FLINK-38112) Change default of yarn.application-attempt-failures-validity-interval to -1

2025-07-17 Thread yude (Jira)
yude created FLINK-38112: Summary: Change default of yarn.application-attempt-failures-validity-interval to -1 Key: FLINK-38112 URL: https://issues.apache.org/jira/browse/FLINK-38112 Project: Flink

[jira] [Created] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service

2025-07-17 Thread yuan (Jira)
yuan created FLINK-38111: Summary: Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service Key: FLINK-38111 URL: https://issues.apache.org/jira/browse/FLINK-38111 Project: Flink I