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

2024-07-19 Thread Xintong Song
+1(binding) Best, Xintong On Thu, Jul 18, 2024 at 9:40 AM weijie guo wrote: > +1(binding) > > Best regards, > > Weijie > > > Wencong Liu 于2024年7月17日周三 21:31写道: > > > Hi dev, > > > > I'd like to start a vote on FLIP-466. > > > > Discussion thread: > > https://lists.apache.org/thread/sw2or622

Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join

2024-07-19 Thread Zhu Zhu
+1 for the FLIP It's a good start to adaptively optimize the logical execution plan with runtime information. Thanks, Zhu Xia Sun 于2024年7月18日周四 18:23写道: > Hi devs, > > Junrui Lee, Lei Yang, and I would like to initiate a discussion about > FLIP-470: Support Adaptive Broadcast Join[1]. > > In g

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

2024-07-19 Thread Xintong Song
+1 (binding) - reviewed flink-web PR - verified checksum and signature - verified source archives don't contain binaries - built from source - tried example jobs on a standalone cluster, and everything looks fine Best, Xintong On Thu, Jul 18, 2024 at 4:25 PM Rui Fan <1996fan...@gmail.com> wro

[jira] [Created] (FLINK-35868) Bump Mongo driver version to support Mongo 7.0+

2024-07-19 Thread yux (Jira)
yux created FLINK-35868: --- Summary: Bump Mongo driver version to support Mongo 7.0+ Key: FLINK-35868 URL: https://issues.apache.org/jira/browse/FLINK-35868 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
Grzegorz Kołakowski created FLINK-35869: --- Summary: Right side columns of temporal left join are always null when right side is filtered Key: FLINK-35869 URL: https://issues.apache.org/jira/browse/FLINK-35869

[DISCUSS] FLIP-XXX Amazon SQS Source Connector

2024-07-19 Thread Saurabh Singh
Hi Fink Devs, Our team has been working on migrating various data pipelines to Flink to leverage the benefits of exactly-once processing, checkpointing, and stateful computing. We have several use cases built around the AWS SQS Service. For this migration, we have developed an SQS Source Connector

Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-07-19 Thread Kevin Lam
Hi all, I had chimed in on Anupam's PR that we might have some time to look at this issue FLINK-34440. Adding @David Mariassy to this thread, as he's started to work

Re: Potential Kafka Connector FLIP: Large Message Handling

2024-07-19 Thread Kevin Lam
Apologies David, here's a temporary link to the image: https://screenshot.click/19-19-0xwls-jfx7s.png On Thu, Jul 18, 2024 at 9:00 AM David Radley wrote: > Hi Kevin, > That sounds good, unfortunately the image did not come through in the > email for me,kind regards, David > > From: Kevin La