[jira] [Created] (FLINK-37987) Implement JdbcDynamicTableSinkV2 to use new Sink API v2

2025-06-24 Thread Poorvank Bhatia (Jira)
Poorvank Bhatia created FLINK-37987: --- Summary: Implement JdbcDynamicTableSinkV2 to use new Sink API v2 Key: FLINK-37987 URL: https://issues.apache.org/jira/browse/FLINK-37987 Project: Flink

Re: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint

2025-06-24 Thread Leonard Xu
Looks like a bug, could you file an issue on jira like [1] ? Best, Leonard [1] https://issues.apache.org/jira/browse/FLINK-34874 > 2025 6月 24 11:50,Qiang He 写道: > > ``` > 2025-06-19 15:17:22,914 INFO > org.apache.flink.cdc.connectors.mysql.source.assigners.MySqlChunkSplitter > [] - The actual

[jira] [Created] (FLINK-37988) Add left join support

2025-06-24 Thread Alan Sheinberg (Jira)
Alan Sheinberg created FLINK-37988: -- Summary: Add left join support Key: FLINK-37988 URL: https://issues.apache.org/jira/browse/FLINK-37988 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-37989) Add condition support

2025-06-24 Thread Alan Sheinberg (Jira)
Alan Sheinberg created FLINK-37989: -- Summary: Add condition support Key: FLINK-37989 URL: https://issues.apache.org/jira/browse/FLINK-37989 Project: Flink Issue Type: Sub-task Re

[SUMMARY] Flink 2.1 Release Sync 06/25/2025

2025-06-24 Thread Ron Liu
Hi, devs, This is the first meeting for Flink 2.1 release cycle after feature freeze. I'd like to share the information synced in the meeting. - Feature Freeze On June 21th we announced the 2.1 feature freeze in the thread[1], and as planned, I'll cut out the release-2.1 branch on the 25th a

[jira] [Created] (FLINK-37990) [Umbrella] Test Flink Release 2.1

2025-06-24 Thread dalongliu (Jira)
dalongliu created FLINK-37990: - Summary: [Umbrella] Test Flink Release 2.1 Key: FLINK-37990 URL: https://issues.apache.org/jira/browse/FLINK-37990 Project: Flink Issue Type: Improvement

Re: Re: Help - Question on triaging slowness

2025-06-24 Thread Siva Ram Gujju
Thank you for the suggestion. I am able to identify the issue. The delay is caused by the combination of my sink and the managed memory allocation. On Tue, Jun 24, 2025 at 4:52 AM Xuyang wrote: > Hi, Siva. > > Additionally, you can temporarily set the Flink configuration > `pipeline.operator-ch

Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal

2025-06-24 Thread Nicolas Fraison
Hi, I will leave this under discussion until next monday then if no comments are provided I will put it to vote. Regards, Nicolas On Tue, Jun 24, 2025 at 8:54 AM Gabor Somogyi wrote: > Thanks for your efforts! > The FLIP looks good from my side. > > G > > > On Tue, Jun 24, 2025 at 7:22 AM Nic

Re: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint

2025-06-24 Thread Qiang He
I don't have a Jira account yet, can you help to submit it? Leonard Xu 于2025年6月24日周二 13:33写道: > Looks like a bug, could you file an issue on jira like [1] ? > > Best, > Leonard > [1] https://issues.apache.org/jira/browse/FLINK-34874 > > > > 2025 6月 24 11:50,Qiang He 写道: > > > > ``` > > 2025-06-

Re: Help - Question on triaging slowness

2025-06-24 Thread Matt Cuento
Hi Siva, Unfortunately the picture attached does not render for me. Would you be able to send the output of what an `EXPLAIN` statement reveals as your logical plan? This is a good first step to getting an idea of what each operator is doing. Degraded performance over time/after processing many r

[jira] [Created] (FLINK-37984) Move Cassandra Sink to Sink V2

2025-06-24 Thread Poorvank Bhatia (Jira)
Poorvank Bhatia created FLINK-37984: --- Summary: Move Cassandra Sink to Sink V2 Key: FLINK-37984 URL: https://issues.apache.org/jira/browse/FLINK-37984 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal

2025-06-24 Thread Gabor Somogyi
Thanks for your efforts! The FLIP looks good from my side. G On Tue, Jun 24, 2025 at 7:22 AM Nicolas Fraison < nicolas.frai...@datadoghq.com> wrote: > Hi, > > This remaining part of the doc has been updated > > On Thu, Jun 19, 2025 at 9:37 AM Gabor Somogyi > wrote: > >> I think in this SSLCont

Re:Re: Help - Question on triaging slowness

2025-06-24 Thread Xuyang
Hi, Siva. Additionally, you can temporarily set the Flink configuration `pipeline.operator-chaining: false` to unchain all operators. This will allow you to see if one specific operator is particularly busy, which could cause backpressure for all of its inputs. -- Best! Xuyang

[jira] [Created] (FLINK-37985) Refactor public config options from StreamConfig to JobConfiguration

2025-06-24 Thread Rui Fan (Jira)
Rui Fan created FLINK-37985: --- Summary: Refactor public config options from StreamConfig to JobConfiguration Key: FLINK-37985 URL: https://issues.apache.org/jira/browse/FLINK-37985 Project: Flink I

[jira] [Created] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP

2025-06-24 Thread Aleksandr Iushmanov (Jira)
Aleksandr Iushmanov created FLINK-37986: --- Summary: CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP Key: FLINK-37986 URL: https://issues.apache.org/jira/browse/FLINK-