Question on lookup joins

2023-12-15 Thread David Radley
Hi , I am working on FLINK-33365 which related to JDBC predicate pushdown. I want to ensure that the same results occur with predicate pushdown as without. So I am asking this question outside the pr / issue. I notice the following behaviour for lookup joins without predicate pushdown. I was

Re: [DISCUSS] Release flink-connector-parent v1.01

2023-12-15 Thread Ryan Skraba
Hello! I've been following this discussion (while looking and building a lot of the connectors): +1 (non-binding) to doing a 1.1.0 release adding the configurability of surefire and jvm flags. Thanks for driving this! Ryan On Fri, Dec 15, 2023 at 2:06 PM Etienne Chauchot wrote: > > Hi PMC

[RESULT][VOTE] FLIP-396: Trial to test GitHub Actions as an alternative for Flink's current Azure CI infrastructure

2023-12-15 Thread Matthias Pohl
The vote for FLIP-396 [1]: Trial to test GitHub Actions as an alternative for Flink's current Azure CI infrastructure (discussion thread [2]) concluded. I'm closing the vote [3]. FLIP-396 was accepted with 10 binding votes and 3 non-binding votes and no -1 votes. Rui Fan (binding) Weijie Guo

[jira] [Created] (FLINK-33858) CI fails with No space left on device

2023-12-15 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33858: --- Summary: CI fails with No space left on device Key: FLINK-33858 URL: https://issues.apache.org/jira/browse/FLINK-33858 Project: Flink Issue Type: Bug

Re: [VOTE] FLIP-335: Deprecation and removal of Flink's Time classes in favor of Java's Duration

2023-12-15 Thread Matthias Pohl
Thanks for participating in this vote. @Xintong you didn't miss the FLIP discussion [1]. :) Anyway, I'm closing this vote thread. The results will be announced in a separate message. Matthias [1] https://lists.apache.org/thread/t540zg3j3womyjcrwrvkwp9p4vfps6t4 On Wed, Dec 13, 2023 at 6:33 AM

[RESULT][VOTE] FLIP-335: Removing Flink's Time classes in favor of Java's Duration class

2023-12-15 Thread Matthias Pohl
The vote for FLIP-335 [1]: Removal of Flink's Time classes in favor of Java's Duration class (discussion thread [2]) concluded. I'm closing the vote [3]. 3 positive binding votes were made: Zhu Zhu (binding) Jing Ge (binding) Xintong Song (binding) There were no -1 votes. Therefore, FLIP-335

Re: [VOTE] FLIP-396: Trial to test GitHub Actions as an alternative for Flink's current Azure CI infrastructure

2023-12-15 Thread Matthias Pohl
Thank you everyone for participating in the vote. I'm closing this vote now and will announce the results in a separate thread. Best, Matthias On Thu, Dec 14, 2023 at 4:38 AM Xuannan Su wrote: > Thanks for driving this! > > +1(non-binding) > > Best, > Xuannan > > On Thu, Dec 14, 2023 at 11:04 

Re: [DISCUSS] FLIP-400: AsyncScalarFunction for asynchronous scalar function support

2023-12-15 Thread Alan Sheinberg
Thanks for the replies everyone. My responses are inline: About the configs, what do you think using hints as mentioned in [1]. @Aitozi: I think hints could be a good way to do this, similar to lookup joins or the proposal in FLIP-313. One benefit of hints is that they allow for the highest

[jira] [Created] (FLINK-33861) Implement restore tests for WindowRank node

2023-12-15 Thread Bonnie Varghese (Jira)
Bonnie Varghese created FLINK-33861: --- Summary: Implement restore tests for WindowRank node Key: FLINK-33861 URL: https://issues.apache.org/jira/browse/FLINK-33861 Project: Flink Issue

[jira] [Created] (FLINK-33859) Support OpenSearch v2

2023-12-15 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33859: --- Summary: Support OpenSearch v2 Key: FLINK-33859 URL: https://issues.apache.org/jira/browse/FLINK-33859 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33860) Implement restore tests for WindowTableFunction node

2023-12-15 Thread Bonnie Varghese (Jira)
Bonnie Varghese created FLINK-33860: --- Summary: Implement restore tests for WindowTableFunction node Key: FLINK-33860 URL: https://issues.apache.org/jira/browse/FLINK-33860 Project: Flink

[jira] [Created] (FLINK-33862) Flink Unit Test Failures on 1.18.0

2023-12-15 Thread Prabhu Joseph (Jira)
Prabhu Joseph created FLINK-33862: - Summary: Flink Unit Test Failures on 1.18.0 Key: FLINK-33862 URL: https://issues.apache.org/jira/browse/FLINK-33862 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33863) Compressed Operator state restore failed

2023-12-15 Thread Ruibin Xing (Jira)
Ruibin Xing created FLINK-33863: --- Summary: Compressed Operator state restore failed Key: FLINK-33863 URL: https://issues.apache.org/jira/browse/FLINK-33863 Project: Flink Issue Type: Bug

Re: [VOTE] FLIP-380: Support Full Partition Processing On Non-keyed DataStream

2023-12-15 Thread weijie guo
+1 (binding) Best regards, Weijie Wencong Liu 于2023年12月15日周五 09:15写道: > Hi dev, > > I'd like to start a vote on FLIP-380. > > Discussion thread: > https://lists.apache.org/thread/nn7myj7vsvytbkdrnbvj5h0homsjrn1h > FLIP: >

[jira] [Created] (FLINK-33854) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots time

2023-12-15 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33854: - Summary: YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots times out Key:

[jira] [Created] (FLINK-33855) send flag message like checkpoint barrier

2023-12-15 Thread Spongebob (Jira)
Spongebob created FLINK-33855: - Summary: send flag message like checkpoint barrier Key: FLINK-33855 URL: https://issues.apache.org/jira/browse/FLINK-33855 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-33856) Add metrics to monitor the interaction performance between task and external storage system in the process of checkpoint making

2023-12-15 Thread Jufang He (Jira)
Jufang He created FLINK-33856: - Summary: Add metrics to monitor the interaction performance between task and external storage system in the process of checkpoint making Key: FLINK-33856 URL:

Re: [VOTE] FLIP-380: Support Full Partition Processing On Non-keyed DataStream

2023-12-15 Thread Yuxin Tan
Thanks Wencong for driving the Flip. +1(non-binding) Best, Yuxin Wencong Liu 于2023年12月15日周五 09:15写道: > Hi dev, > > I'd like to start a vote on FLIP-380. > > Discussion thread: > https://lists.apache.org/thread/nn7myj7vsvytbkdrnbvj5h0homsjrn1h > FLIP: >

Re: [VOTE] FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

2023-12-15 Thread Yuxin Tan
+1 (non-binding) Best, Yuxin weijie guo 于2023年12月15日周五 10:05写道: > +1(binding) > > Best regards, > > Weijie > > > Wencong Liu 于2023年12月15日周五 09:13写道: > > > Hi dev, > > > > I'd like to start a vote on FLIP-382. > > > > Discussion thread: > >

Re: [DISCUSS] FLIP-400: AsyncScalarFunction for asynchronous scalar function support

2023-12-15 Thread Timo Walther
1. Override the function `getRequirements` in `AsyncScalarFunction` > If the user overrides `requirements()` to omit the `ORDERED` > requirement, do we allow the operator to return out-of-order results > or should it fall back on `AsyncOutputMode.ALLOW_UNORDERED` type > behavior (where we allow

Re: [DISCUSS] Release flink-connector-parent v1.01

2023-12-15 Thread Etienne Chauchot
Hi PMC members, Version will be 1.1.0 and not 1.0.1 as one of the PMC members already created this version tag in jira and tickets are targeted to this version. Anyone for pushing my pub key to apache dist ? Thanks Etienne Le 14/12/2023 à 17:51, Etienne Chauchot a écrit : Hi all, It has

[jira] [Created] (FLINK-33857) Expose BulkProcessor.flush via RequestIndexer to allow custom flush logic

2023-12-15 Thread Peter Schulz (Jira)
Peter Schulz created FLINK-33857: Summary: Expose BulkProcessor.flush via RequestIndexer to allow custom flush logic Key: FLINK-33857 URL: https://issues.apache.org/jira/browse/FLINK-33857 Project: