Re: [VOTE] FLIP-372: Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable

2023-12-21 Thread Péter Váry
We have enough votes for the decision, but given that this is an important change, and for many of us it is a holiday season, I plan to keep this vote open until the 3rd of January. This way, if anyone else has comments and suggestions then they have time to raise them. Thanks everyone for the

[jira] [Created] (FLINK-33927) Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS)

2023-12-21 Thread Yubin Li (Jira)
Yubin Li created FLINK-33927: Summary: Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS) Key: FLINK-33927 URL:

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

2023-12-21 Thread Jim Hughes
Hi Alan, +1 (non binding) Cheers, Jim On Wed, Dec 20, 2023 at 2:41 PM Alan Sheinberg wrote: > Hi everyone, > > I'd like to start a vote on FLIP-400 [1]. It covers introducing a new UDF > type, AsyncScalarFunction for completing invocations asynchronously. It > has been discussed in this

[jira] [Created] (FLINK-33926) Can't start a job with a jar in the system classpath in native k8s mode

2023-12-21 Thread Trystan (Jira)
Trystan created FLINK-33926: --- Summary: Can't start a job with a jar in the system classpath in native k8s mode Key: FLINK-33926 URL: https://issues.apache.org/jira/browse/FLINK-33926 Project: Flink

Re: [VOTE] Release flink-connector-pulsar 4.1.0, release candidate #1

2023-12-21 Thread Leonard Xu
+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked the contents contains jar and pom files in apache repo - checked Github release tag - checked release notes Best, Leonard > 2023年12月21日 下午5:03,Danny Cranmer 写道: > > Hello, > > Thanks for

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

2023-12-21 Thread Maximilian Michels
> Anyone for pushing my pub key to apache dist ? Done. On Thu, Dec 21, 2023 at 2:36 PM Etienne Chauchot wrote: > > Hello, > > All the ongoing PRs on this repo were merged. But, I'd like to leave > some more days until feature freeze in case someone had a feature ready > to integrate. > > Let'

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

2023-12-21 Thread Etienne Chauchot
Hello, All the ongoing PRs on this repo were merged. But, I'd like to leave some more days until feature freeze in case someone had a feature ready to integrate. Let' put the feature freeze to  00:00:00 UTC on December 27th. Best Etienne Le 15/12/2023 à 16:41, Ryan Skraba a écrit :

[jira] [Created] (FLINK-33925) Extended failure handling for bulk requests (elasticsearch back port)

2023-12-21 Thread Peter Schulz (Jira)
Peter Schulz created FLINK-33925: Summary: Extended failure handling for bulk requests (elasticsearch back port) Key: FLINK-33925 URL: https://issues.apache.org/jira/browse/FLINK-33925 Project: Flink

Re:Re: [DISCUSS] FLIP-392: Deprecate the Legacy Group Window Aggregation

2023-12-21 Thread Xuyang
Hi, Timo. Sorry to bother you. There's something I really need to hear your thoughts on. When I'm trying to split this flip, having reviewed this discussion and the FLIP document again, I realized that there is still a key issue that hasn't been clarified. The key reason the original FLIP

[DISCUSS] FLINK-33857 connector-opensearch|elasticsearch: expose flush

2023-12-21 Thread Peter Fischer
Hi! We encountered a bug in elasticsearch recently that prevents us from using the flink connectors for opensearch|elaticsearch: size estimations for bulk requests ignore potentially large parameter values, see [1]. As a workaround, we patched the connector to expose the flush method of the

Re: Re: [DISCUSS] FLIP-387: Support named parameters for functions and call procedures

2023-12-21 Thread Benchao Li
I'm glad to hear that this is in your plan. Sorry that I overlooked the PoC link in the FLIP previously, I'll go over the code of PoC, and post here if there are any more concerns. Xuyang 于2023年12月21日周四 10:39写道: > > Hi, Benchao. > > > When Feng Jin and I tried the poc together, we found that

[jira] [Created] (FLINK-33924) Register for INFRA's self-hosted runner trial

2023-12-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33924: - Summary: Register for INFRA's self-hosted runner trial Key: FLINK-33924 URL: https://issues.apache.org/jira/browse/FLINK-33924 Project: Flink Issue Type:

Re: [VOTE] FLIP-372: Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable

2023-12-21 Thread Leonard Xu
Thanks Peter for quick response and update. I’ve no more comments on the updated FLIP, +1. For the PR process, you could alsouse draft PR[1] to leverage the testing infra during POC phase, we usually create FLIP umbrella issue and subtask issues after the FLIP is accepted. Best, Leonard

[jira] [Created] (FLINK-33923) Upgrade upload-artifacts and download-artifacts to version 4

2023-12-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33923: - Summary: Upgrade upload-artifacts and download-artifacts to version 4 Key: FLINK-33923 URL: https://issues.apache.org/jira/browse/FLINK-33923 Project: Flink

Re: [VOTE] FLIP-372: Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable

2023-12-21 Thread Péter Váry
Thanks Leonard for the review! See my answers below: Leonard Xu ezt írta (időpont: 2023. dec. 21., Cs, 9:00): > Thanks Peter for driving this. > > The FLIP change is a big improvement of the existing sink v2 interfaces, > but the FLIP's overall API design taste and interface style looks good

[jira] [Created] (FLINK-33922) table-planner jar will be removed as it is created at /tmp by default

2023-12-21 Thread Guojun Li (Jira)
Guojun Li created FLINK-33922: - Summary: table-planner jar will be removed as it is created at /tmp by default Key: FLINK-33922 URL: https://issues.apache.org/jira/browse/FLINK-33922 Project: Flink

[jira] [Created] (FLINK-33921) Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

2023-12-21 Thread Yubin Li (Jira)
Yubin Li created FLINK-33921: Summary: Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig Key: FLINK-33921 URL:

Re: [VOTE] Release flink-connector-pulsar 4.1.0, release candidate #1

2023-12-21 Thread Danny Cranmer
Hello, Thanks for driving, Leonard, +1 (binding) - Verified signatures and checksums of source and binaries - Maven dist contains expected files - There are no binaries in the source archive - Release notes look good - Tag exists in Github - CI passes for v4.1 [1] (could not find a tag build,

Re: [VOTE] FLIP-364: Update the default value of backoff-multiplier from 1.2 to 1.5

2023-12-21 Thread Zakelly Lan
This makes sense. +1 (non-binding) Best, Zakelly On Thu, Dec 21, 2023 at 1:50 PM Jiabao Sun wrote: > +1 (non-binding) > > Best, > Jiabao > > > > 2023年12月21日 13:25,weijie guo 写道: > > > > +1(binding) > > > > Best regards, > > > > Weijie > > > > > > Xin Jiang 于2023年12月21日周四 11:21写道: > > > >>

[jira] [Created] (FLINK-33920) StandaloneKubernetesTaskManagerFactory doesn't support recent config additions

2023-12-21 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-33920: -- Summary: StandaloneKubernetesTaskManagerFactory doesn't support recent config additions Key: FLINK-33920 URL: https://issues.apache.org/jira/browse/FLINK-33920 Project: