[jira] [Created] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase

2024-11-25 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-36798: -- Summary: Improve data processing speed during the phase from snapshot to incremental phase Key: FLINK-36798 URL: https://issues.apache.org/jira/browse/FLINK-36798 Project

[jira] [Created] (FLINK-36797) hudi sink支持pipeline配置方式的connector

2024-11-25 Thread Jira
林健昌 created FLINK-36797: --- Summary: hudi sink支持pipeline配置方式的connector Key: FLINK-36797 URL: https://issues.apache.org/jira/browse/FLINK-36797 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-36796) oracle cdc支持pipeline配置方式的connector

2024-11-25 Thread Jira
林健昌 created FLINK-36796: --- Summary: oracle cdc支持pipeline配置方式的connector Key: FLINK-36796 URL: https://issues.apache.org/jira/browse/FLINK-36796 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-36795) postgres cdc支持pipeline配置方式的connector

2024-11-25 Thread Jira
林健昌 created FLINK-36795: --- Summary: postgres cdc支持pipeline配置方式的connector Key: FLINK-36795 URL: https://issues.apache.org/jira/browse/FLINK-36795 Project: Flink Issue Type: Improvement Report

[jira] [Created] (FLINK-36794) mysql cdc和postgres cdc对于分表分库场景的支持

2024-11-25 Thread Jira
林健昌 created FLINK-36794: --- Summary: mysql cdc和postgres cdc对于分表分库场景的支持 Key: FLINK-36794 URL: https://issues.apache.org/jira/browse/FLINK-36794 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-36793) oracle cdc的增量快照的块分割器逻辑有问题导致分割的片过大的问题

2024-11-25 Thread Jira
林健昌 created FLINK-36793: --- Summary: oracle cdc的增量快照的块分割器逻辑有问题导致分割的片过大的问题 Key: FLINK-36793 URL: https://issues.apache.org/jira/browse/FLINK-36793 Project: Flink Issue Type: Improvement Componen

Re: [DISCUSS] Flink 1.20.1 release

2024-11-25 Thread Yuepeng Pan
Thanks for driving this ! +1 for a 1.20.1 release, And there's a pending issue here[1][2], and judging by the results of the current email thread[3] call for comments, it seems need to be merged into the 1.x series. Would we consider merging it into these two upcoming releases? I'd like to do

[jira] [Created] (FLINK-36792) FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed

2024-11-25 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-36792: - Summary: FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed Key: FLINK-36792 URL: https://issues.apache.org/jira/browse/FLINK-36792 Project:

Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1

2024-11-25 Thread Leonard Xu
+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code with JDK 1.8 succeeded - checked release notes - reviewed the web PR Best, Leonard > On Nov 21, 2024, at 8:09 PM, Yanquan Lv wrote: > > +1 (non-binding) > I checked: > - Review JIRA r

[jira] [Created] (FLINK-36791) FlinkPruneEmptyRules can be removed because high version calcite has fixed

2024-11-25 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-36791: - Summary: FlinkPruneEmptyRules can be removed because high version calcite has fixed Key: FLINK-36791 URL: https://issues.apache.org/jira/browse/FLINK-36791 Project: Flink

[jira] [Created] (FLINK-36790) Flink CDC to Paimon: DeletionVectorsMaintainer CME problem

2024-11-25 Thread Rascal Wu (Jira)
Rascal Wu created FLINK-36790: - Summary: Flink CDC to Paimon: DeletionVectorsMaintainer CME problem Key: FLINK-36790 URL: https://issues.apache.org/jira/browse/FLINK-36790 Project: Flink Issue Ty

Re: [DISCUSS] Flink 1.20.1 release

2024-11-25 Thread Tom Cooper
+1 for a 1.20.1 release, thanks for driving this Alex. I am new to Flink and not totally clear on the release process. Is there going to be a code freeze date? There are a number of CVE fixes ([1],[2]) I would really like to be included. Tom Cooper [1](https://github.com/apache/flink/pull/2557

Re: [DISCUSS] Flink 1.20.1 release

2024-11-25 Thread Roman Khachatryan
+1, Thanks for volunteering! Regards, Roman On Mon, Nov 25, 2024 at 5:35 AM Zakelly Lan wrote: > +1 for this > > Thanks for driving! > > Best, > Zakelly > > On Mon, Nov 25, 2024 at 12:15 PM weijie guo > wrote: > > > Thanks for driving this! > > > > +1 for this release and rm. > > > > Best re

[RESULT][VOTE] flink-connector-kafka 3.4.0, release candidate #1

2024-11-25 Thread Arvid Heise
I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * Yanquan Lv * Leonard Xu (binding) * Martijn Visser (binding) * Ahmed Hamdy * Danny Cranmer (binding) There are no disapproving votes. Thanks everyone! Arvid

Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1

2024-11-25 Thread Arvid Heise
Thank you all for verifying and voting. I'm closing this vote and I'll announce the result. Best, Arvid On Mon, Nov 25, 2024 at 3:56 PM Danny Cranmer wrote: > Thanks for driving this release Arvid, > > +1 (binding) > > - Release notes look good > - Validated source archive signature & checksum

[jira] [Created] (FLINK-36789) Update FunctionHint and ArgumentHint with StaticArguments

2024-11-25 Thread Timo Walther (Jira)
Timo Walther created FLINK-36789: Summary: Update FunctionHint and ArgumentHint with StaticArguments Key: FLINK-36789 URL: https://issues.apache.org/jira/browse/FLINK-36789 Project: Flink Iss

Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1

2024-11-25 Thread Danny Cranmer
Thanks for driving this release Arvid, +1 (binding) - Release notes look good - Validated source archive signature & checksum - Validated binary signature & checksum - Verified no binaries in source archive - Verified CI build of tag passed - Verified contents of Maven repo. Nit: the URL should b

RE: [jira] [Created] (FLINK-36739) Update NodeJS to v18.20.5 (LTS)

2024-11-25 Thread Mehdi Deboub
Hello, This issue is currently blocked by the CI build which has Ubuntu version 16.04 and the new NodeJS version requires a newer Ubuntu version (from 20.04). We have seen the problem https://issues.apache.org/jira/browse/FLINK-34194 which deals with updating the build CI image used in the Flink bu

[jira] [Created] (FLINK-36788) Add coverage for GlobalCommitter for SinkV2

2024-11-25 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-36788: --- Summary: Add coverage for GlobalCommitter for SinkV2 Key: FLINK-36788 URL: https://issues.apache.org/jira/browse/FLINK-36788 Project: Flink Issue Type: Bug

RE: FW: Re: Flink technical debt.

2024-11-25 Thread David Radley
Hi Sergey, Thanks for your thoughts 😊 1. Yes I agree – it did not look like I have authority to add labels. 2. Yes, in the case of CI failures, I was hoping that the submitter would investigate rather than the triaging group. We are hoping to add value quickly and push the pr back to subm

Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler

2024-11-25 Thread yuanfeng hu
+1, I think this feature is very useful for adaptive scheduler. Yuepeng Pan 于2024年11月22日周五 18:38写道: > Hi community, > > > > > Currently, the Adaptive Scheduler already supports the REST API > > to manually adjust[1] the parallelism of jobs, which enhances the > > functionality of the Adaptive Sc

Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1

2024-11-25 Thread Ahmed Hamdy
+1 (non-binding) - Validated hashes & checksums - Validated signatures - Verified no binaries in source archive - Build source with maven Best Regards Ahmed Hamdy On Mon, 25 Nov 2024 at 08:50, Martijn Visser wrote: > +1 (binding) > > - Validated hashes > - Verified signature > - Verified that

Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1

2024-11-25 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR On Thu, Nov 21, 2024 at 9:56 AM Leonard Xu wrote: > +1 (binding) > > - verified signatures > - verified hashsums > - c

[jira] [Created] (FLINK-36787) Flink SQL mode kafka join jdbc Dimension Table Yarn node OOM

2024-11-25 Thread zhengyuan (Jira)
zhengyuan created FLINK-36787: - Summary: Flink SQL mode kafka join jdbc Dimension Table Yarn node OOM Key: FLINK-36787 URL: https://issues.apache.org/jira/browse/FLINK-36787 Project: Flink Issu

[jira] [Created] (FLINK-36786) Memory leak in SplitFetcherManager#close

2024-11-25 Thread Zhen Wang (Jira)
Zhen Wang created FLINK-36786: - Summary: Memory leak in SplitFetcherManager#close Key: FLINK-36786 URL: https://issues.apache.org/jira/browse/FLINK-36786 Project: Flink Issue Type: Improvement