[jira] [Created] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink.

2024-07-22 Thread LvYanquan (Jira)
LvYanquan created FLINK-35873: - Summary: Add HashFunctionProvider for Paimon DataSink. Key: FLINK-35873 URL: https://issues.apache.org/jira/browse/FLINK-35873 Project: Flink Issue Type: New Featu

Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector

2024-07-22 Thread Saurabh Singh
Hi Yanquan, Yes, you are right about SQS - It is a MessageQueue. https://aws.amazon.com/sqs/features/ Thanks for reviewing the FLIP and valuable suggestions about adding observability. We have reviewed the above-mentioned Standardize Connector Metric FLIP [1] and added a section about it in the

[jira] [Created] (FLINK-35874) Check pureBinlogPhaseTables set before call getBinlogPosition method in BinlogSplitReader

2024-07-22 Thread Zhongmin Qiao (Jira)
Zhongmin Qiao created FLINK-35874: - Summary: Check pureBinlogPhaseTables set before call getBinlogPosition method in BinlogSplitReader Key: FLINK-35874 URL: https://issues.apache.org/jira/browse/FLINK-35874

Re: [VOTE] FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

2024-07-22 Thread Li Wang
+1 (non-binding) from me as well. This would help in multiple use-cases. Thanks On Mon, Jul 22, 2024 at 11:47 AM Rui Fan <1996fan...@gmail.com> wrote: > Thanks Wencong for driving this proposal! > > +1(binding) > > Best, > Rui > > On Fri, Jul 19, 2024 at 3:58 PM Xintong Song > wrote: > > > +1(b

Re: PR review request for sql-gateway feature

2024-07-22 Thread Dongwoo Kim
Hi Shengkai, Thank you for introducing an interesting concept of plan advice. After reviewing the FLIP, I thought that plan advice cannot fully replace the original intention of the OperationValidator. Similar to the pluggable ResourceValidator[1] in flink k8s operator, the OperationValidator aims

Re: [VOTE] FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

2024-07-22 Thread Mingliang Liu
+1 (non-binding) on this. Loving these hint-based attributes to gain "managed" optimizations. On Mon, Jul 22, 2024 at 6:15 AM Li Wang wrote: > +1 (non-binding) from me as well. This would help in multiple use-cases. > > Thanks > > On Mon, Jul 22, 2024 at 11:47 AM Rui Fan <1996fan...@gmail.com> w

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

2024-07-22 Thread Ron Liu
Hi, Weijie Sorry about the newly discovered bug affecting the release process. The fix pr of https://issues.apache.org/jira/browse/FLINK-35872 has been merged. Best, Ron Feng Jin 于2024年7月22日周一 10:57写道: > Hi, weijie > > -1 (non-binding) > > During our testing process, we discovered a critical

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

2024-07-22 Thread weijie guo
Hi everyone, This rc is officially cancelled because of the critical bug of materialized table [1] A new rc will be created recently. [1] https://issues.apache.org/jira/browse/FLINK-35872 Best, Robert, Rui, Ufuk, Weijie Ron Liu 于2024年7月23日周二 09:34写道: > Hi, Weijie > > Sorry about the newly

Re: PR review request for sql-gateway feature

2024-07-22 Thread Shengkai Fang
Hi Dongoo, You are right that plan advisor doesn't have ability to block user request. Actually, we add a new REST API in the gateway side to validate the users request is legal or not in our inner branch. Therefore, user can validate their statements before execution or execute their statement di

[jira] [Created] (FLINK-35875) Flink cdc frequently encounters LabelAlreadyExists errors

2024-07-22 Thread Jira
牛一凡 created FLINK-35875: --- Summary: Flink cdc frequently encounters LabelAlreadyExists errors Key: FLINK-35875 URL: https://issues.apache.org/jira/browse/FLINK-35875 Project: Flink Issue Type: Bug