[jira] [Created] (FLINK-37328) Upgrade GCS Connector to 2.2.26.

Chris Nauroth created FLINK-37328: - Summary: Upgrade GCS Connector to 2.2.26. Key: FLINK-37328 URL: https://issues.apache.org/jira/browse/FLINK-37328 Project: Flink Issue Type: Improvement

Question about in-place rescaling support in Flink k8s operator

Hi, I have a few questions on in-place rescaling support in Flink k8s operator. 1. Seems it is in the development roadmap . Is there a plan for developing it? Any discussion threads that I can follow

[VOTE] FLIP-491: BundledAggregateFunction for batched aggregation

Hi everyone, I'd like to start a vote on FLIP-491 [1]. It proposes adding BundledAggregateFunction as an interface that aggregate function UDFs can implement. The interface exposes a batch method which should make calling out to external services more efficient, whether fetching data or doing remo

[jira] [Created] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows

Kevin Lam created FLINK-37327: - Summary: Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows Key: FLINK-37327 URL: https://issues.apache.org/jira/browse/FLINK-37327 Proje

[DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State

Hi everyone, I would like to open a discussion on implementing faster checkpoint & recovery for disaggregated state[1]. This is an improvement work for the disaggregated state management ForSt, so you may want to read FLIP-423[2] and FLIP-428[3] to know the backgrounds. Currently, ForSt copies

[jira] [Created] (FLINK-37326) The transform module reports an error when column is a Java keyword

zexin gong created FLINK-37326: -- Summary: The transform module reports an error when column is a Java keyword Key: FLINK-37326 URL: https://issues.apache.org/jira/browse/FLINK-37326 Project: Flink

Re: Flink 1.18.2 release date

Dear Flink Community, Hi, it's me again regarding this question. Will we still have a release 1.18.2? I'm waiting for a particular fix related to this ticket: https://issues.apache.org/jira/browse/FLINK-34063. Thanks very much, Yang On Fri, 31 May 2024 at 04:02, weijie guo wrote: > Hi Yang > >

[jira] [Created] (FLINK-37325) SQL connector for keyed savepoint data Chinese documentation

Gabor Somogyi created FLINK-37325: - Summary: SQL connector for keyed savepoint data Chinese documentation Key: FLINK-37325 URL: https://issues.apache.org/jira/browse/FLINK-37325 Project: Flink

[jira] [Created] (FLINK-37324) RocksDB keys iterator performance improvement

Gabor Somogyi created FLINK-37324: - Summary: RocksDB keys iterator performance improvement Key: FLINK-37324 URL: https://issues.apache.org/jira/browse/FLINK-37324 Project: Flink Issue Type: I

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

Hi Xiangyu and Ron, I agree that sink reuse can be enabled by default from Flink Planner perspective. But the planner should be informed by Sink Connector that whether the planner can reuse different sink with different target columns. Take JBDC sink as an example, under partial update circumstan