[jira] [Created] (FLINK-37285) Adapt DataSinkTranslator to support new Sink API of FLIP-372

Yanquan Lv created FLINK-37285: -- Summary: Adapt DataSinkTranslator to support new Sink API of FLIP-372 Key: FLINK-37285 URL: https://issues.apache.org/jira/browse/FLINK-37285 Project: Flink Iss

[jira] [Created] (FLINK-37284) ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch.

Junrui Lee created FLINK-37284: -- Summary: ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. Key: FLINK-37284 URL: https://issues.apache.org/jira/browse/FLINK-37284 Project: Flink

[jira] [Created] (FLINK-37283) Improved ability to split ‘db./.*./.*.’

ouyangwulin created FLINK-37283: --- Summary: Improved ability to split ‘db./.*./.*.’ Key: FLINK-37283 URL: https://issues.apache.org/jira/browse/FLINK-37283 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37282) Add backchannel for producer recycling

Arvid Heise created FLINK-37282: --- Summary: Add backchannel for producer recycling Key: FLINK-37282 URL: https://issues.apache.org/jira/browse/FLINK-37282 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37281) Refactor KafkaSinkITCase

Arvid Heise created FLINK-37281: --- Summary: Refactor KafkaSinkITCase Key: FLINK-37281 URL: https://issues.apache.org/jira/browse/FLINK-37281 Project: Flink Issue Type: Improvement Comp

Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation

Hi all, Is there any more feedback I can incorporate before calling a vote? Thanks, Alan On Tue, Jan 28, 2025 at 1:50 PM Alan Sheinberg wrote: > Hi Fabian, > > I addressed your comments below. > > >> * BundledKeySegement >> * should it be accumulatorS instead of accumulator? >> * should ac

Minutes of the Community Health Initiative (CHI) for Western time zone

Hi all, We have the 10th 30 minute working meeting of the Community Health Initiative (CHI) for Western time zone. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=340036713 In addition to triaging PRs we discussed: * 14 PRs came in this week. >From this week we need to com

[jira] [Created] (FLINK-37280) Inconsistent content of TableConfig in planner when mini batch is enabled

Piotr Nowojski created FLINK-37280: -- Summary: Inconsistent content of TableConfig in planner when mini batch is enabled Key: FLINK-37280 URL: https://issues.apache.org/jira/browse/FLINK-37280 Project

Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans

Thanks Timo for the extra info on the context of this change. +1 Gyula On Fri, Feb 7, 2025 at 5:05 PM Timo Walther wrote: > Hi Gyula, > > Sergey and I spent a significant amount of time in researching different > formats. > > When we introduced CompiledPlan, the question whether we want to use

Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans

Hi Gyula, Sergey and I spent a significant amount of time in researching different formats. When we introduced CompiledPlan, the question whether we want to use a binary format for performance and efficiency reasons immediately came up, but we decided to postpone this discussion. Back then

Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans

Hey! Do we have some examples of other frameworks/projects etc using the Smile format? This seems to be a somewhat arbitrary change with regard to the selected format, my concern is that this will make the compiled plan less useful in general as it's harder to parse with standard tools. What is t

[DISCUSS] FLIP-508: Add support for Smile format for Compiled plans

Hi everyone, I would like to initiate a discussion for the FLIP-508[1] below, which adds support for Smile[2] format for Compiled plans Looking forward to hearing from you. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-508%3A+Add+support+for+Smile+format+for+Compiled+plans [2] https

[jira] [Created] (FLINK-37279) Add Flink CDC Pipeline Clickhouse connector

qinghuan wang created FLINK-37279: - Summary: Add Flink CDC Pipeline Clickhouse connector Key: FLINK-37279 URL: https://issues.apache.org/jira/browse/FLINK-37279 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-37278) Regular schema evolution process is too slow when starting from specific offset

yux created FLINK-37278: --- Summary: Regular schema evolution process is too slow when starting from specific offset Key: FLINK-37278 URL: https://issues.apache.org/jira/browse/FLINK-37278 Project: Flink

[jira] [Created] (FLINK-37277) Add guidance for configuring different kind of catalog of Paimon Sink.

Yanquan Lv created FLINK-37277: -- Summary: Add guidance for configuring different kind of catalog of Paimon Sink. Key: FLINK-37277 URL: https://issues.apache.org/jira/browse/FLINK-37277 Project: Flink

Re: [VOTE] Release 1.20.1, release candidate #1

+1 (binding) 1. Verified the archives, checksums, and signatures 2. Extracted and inspected the source code for binaries 3. Built the source code 4. Reviewed web PR and left one comment Best, Rui On Fri, Feb 7, 2025 at 6:54 PM Gyula Fóra wrote: > +1 (binding) > > - Reviewed release notes > - V

Re: [VOTE] Release 1.20.1, release candidate #1

+1 (binding) - Reviewed release notes - Verified hashes, signatures, built from source - Verified release artifacts - Checked website PR Cheers Gyula On Fri, Feb 7, 2025 at 10:16 AM David Radley wrote: > Hi Alex, > > +1 (non-binding) > I checked: > - Reviewed JIRA release notes > - Verify hash

RE: [VOTE] Release 1.20.1, release candidate #1

Hi Alex, +1 (non-binding) I checked: - Reviewed JIRA release notes - Verify hashes and verify signatures - Source code artifacts matching the current release - Read the announcement blog and LGTM Thanks for the pointers. 1. Yes this worked 2. this did not work but I downloaded the KEYS file and

[jira] [Created] (FLINK-37276) Missing interfaces in `RuntimeContext`

Zakelly Lan created FLINK-37276: --- Summary: Missing interfaces in `RuntimeContext` Key: FLINK-37276 URL: https://issues.apache.org/jira/browse/FLINK-37276 Project: Flink Issue Type: Bug