[jira] [Created] (FLINK-37436) flink-connector-pulsar used a incorrect API when dynamically creating topics by DynamicTopicRouter

Yubiao Feng created FLINK-37436: --- Summary: flink-connector-pulsar used a incorrect API when dynamically creating topics by DynamicTopicRouter Key: FLINK-37436 URL: https://issues.apache.org/jira/browse/FLINK-37436

Re: [DISCUSS] Pluggable Batching for Async Sink in Flink

Hi Poorvank, thanks for the FLIP :) Added some comments on the Google doc. Some of them might be irrelevant since I am not that familiar with the codebase at the moment. Otherwise LGTM On Wed, 5 Mar 2025 at 06:14, Poorvank Bhatia wrote: > Hey everyone, > > Before raising a vote thread, can anyo

2025/03/06 CHI Western time zone workgroup meeting minutes

Hi , We had the 14th 30 minute working meeting of the Community Health Initiative (CHI) for Western time zone. * 18 PRs came in this week * We talked about a contributor role being able to assign Jiras to themselves. But are aware that the current process Flink Jira Process#Assignee

[DISCUSS] Optimizing metrics refresh: fetch metrics by name

Hi all, I’d like to discuss an issue encountered while using Flink OSS autoscaler with jobs that have high parallelism (1k+ subtasks). I’ll share the solution we've implemented internally and would like to hear if others in the community have faced similar challenges. Additionally, I’m curious to

Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released

Hey! I am afraid the OperatorHub hasn't been updated for some time. So I am not sure when / if this will be published there. Let me link some folks who expressed interest in helping with this and hopefully we can get this release there :) Cheers, Gyula On Thu, Mar 6, 2025 at 8:17 AM Graham John

Re: Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it

> > From my understanding, for a sink, if its schema includes a primary key, > we can assume it has > the ability to process delete messages (with '-D') and perform deletions > by key (PK). If it does not > include a PK, we would implicitly treat it as a log-structured table that > supports full ro

Re: Flink CDC to Paimon

Hi Leonard, Yes i did see Xianqian’s reply however i thought my email did not go through as the community is often very active but I did not receive a response until Xianqian’s reply. Thank you Xianqian we are currently trying out the suggestions for altering schema via the catalog. Thank yo

[jira] [Created] (FLINK-37437) ForSt checkpoint failure due to file not visible when writing

Zakelly Lan created FLINK-37437: --- Summary: ForSt checkpoint failure due to file not visible when writing Key: FLINK-37437 URL: https://issues.apache.org/jira/browse/FLINK-37437 Project: Flink