Re: Sink V2 interface replacement for GlobalCommitter

Thanks for the discussion. Favor schemes that allow for custom committer parallelism. This will help us better use the new unified sink. As an added point, in the current scheme, if I want to get some task information, such as jobid operatorid, in writer and commiter methods, it is not easy.

[jira] [Created] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

Aitozi created FLINK-29557: -- Summary: The SinkOperator's OutputFormat function is not recognized Key: FLINK-29557 URL: https://issues.apache.org/jira/browse/FLINK-29557 Project: Flink Issue Type:

Re: Edit permissions to Flink wiki

Hi Abid, I just added the permissions for Abid Mohammed (abmo-x). Best, Jingsong On Mon, Oct 10, 2022 at 9:57 AM Abid Mohammed wrote: > > Hi, > > Can someone please grant me edit permissions so that I can create a new FLIP. > > Thanks > Abid

Re: [DISCUSS] Reverting sink metric name changes made in 1.15

Thanks for driving, Qingsheng. +1 for reverting sink metric name. We often forget that metric is also one of the important APIs. +1 for releasing 1.15.3 to fix this. Best, Jingsong On Sun, Oct 9, 2022 at 11:35 PM Becket Qin wrote: > > Thanks for raising the discussion, Qingsheng, > > +1 on

Re: [Discuss]- Donate Iceberg Flink Connector

Thanks Abid for driving. +1 for this. Can you open the permissions for https://docs.google.com/document/d/1WC8xkPiVdwtsKL2VSPAUgzm9EjrPs8ZRjEtcwv93ISI/edit?usp=sharing ? Best, Jingsong On Mon, Oct 10, 2022 at 9:22 AM Abid Mohammed wrote: > > Hi, > > I would like to start a discussion about

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

+1 (non-binding) - checked sha512 & gpg - tag in the GitHub repo seems ok - no binary files found in the source - check all versions in the pom file nothing suspicious found - compile from source ok - add one comment about the release blog - deploy standalone session cluster & application job,

Edit permissions to Flink wiki

Hi, Can someone please grant me edit permissions so that I can create a new FLIP. Thanks Abid

[Discuss]- Donate Iceberg Flink Connector

Hi, I would like to start a discussion about contributing Iceberg Flink Connector to Flink. I created a doc with all the details following the Flink Connector template as I don’t have

[jira] [Created] (FLINK-29556) flink sql 执行过程报java.lang.NullPointerException异常

Luochg created FLINK-29556: -- Summary: flink sql 执行过程报java.lang.NullPointerException异常 Key: FLINK-29556 URL: https://issues.apache.org/jira/browse/FLINK-29556 Project: Flink Issue Type: Bug

Re: [DISCUSS] Reverting sink metric name changes made in 1.15

Thanks for raising the discussion, Qingsheng, +1 on reverting the breaking changes. In addition, we might want to release a 1.15.3 to fix this and update the previous release docs with this known issue, so that users can upgrade to 1.15.3 when they hit it. It would also be good to add some

[jira] [Created] (FLINK-29555) GlobalStreamingCommitterHandler not call notifyCheckpointCompleted after endOfInput

liwei li created FLINK-29555: Summary: GlobalStreamingCommitterHandler not call notifyCheckpointCompleted after endOfInput Key: FLINK-29555 URL: https://issues.apache.org/jira/browse/FLINK-29555 Project:

Re: [VOTE] FLIP-262: MongoDB Connector

Thanks Jiabao for driving this work. +1(binding) Best, Leonard Xu > 2022年9月30日 下午5:02，jiabao.sun 写道： > > Hi everyone, > > > Thanks for all your feedback for FLIP-262[1]: MongoDB Connector in the > discussion thread[2], > I'd like to start a vote for it. > > > The vote will be open for at

[jira] [Created] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

Jingsong Lee created FLINK-29554: Summary: Add partial-update.ignore-delete option to avoid exception after join Key: FLINK-29554 URL: https://issues.apache.org/jira/browse/FLINK-29554 Project: Flink

[jira] [Created] (FLINK-29553) Support UNIX_TIMESTAMP in Table API

hehuiyuan created FLINK-29553: - Summary: Support UNIX_TIMESTAMP in Table API Key: FLINK-29553 URL: https://issues.apache.org/jira/browse/FLINK-29553 Project: Flink Issue Type: Improvement