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

+1 for this FLIP. I think this is similar to SQL hints, where users can provide optional information to help the engine execute the workload more efficiently. Having a unified mechanism for such kind of hints should improve usability compared to introducing tons of configuration knobs. Best, Xin

[jira] [Created] (FLINK-35713) add

wuzexian created FLINK-35713: Summary: add Key: FLINK-35713 URL: https://issues.apache.org/jira/browse/FLINK-35713 Project: Flink Issue Type: Improvement Reporter: wuzexian -- T

[jira] [Created] (FLINK-35712) [Release-1.20] Prepare RC0 release

Weijie Guo created FLINK-35712: -- Summary: [Release-1.20] Prepare RC0 release Key: FLINK-35712 URL: https://issues.apache.org/jira/browse/FLINK-35712 Project: Flink Issue Type: Sub-task Affec

[jira] [Created] (FLINK-35711) LocalRecoveryITCase failed on AZP due to exit code: 127

Weijie Guo created FLINK-35711: -- Summary: LocalRecoveryITCase failed on AZP due to exit code: 127 Key: FLINK-35711 URL: https://issues.apache.org/jira/browse/FLINK-35711 Project: Flink Issue Typ

[jira] [Created] (FLINK-35710) ClusterEntrypointTest failed on AZP due to exit code: 239

Weijie Guo created FLINK-35710: -- Summary: ClusterEntrypointTest failed on AZP due to exit code: 239 Key: FLINK-35710 URL: https://issues.apache.org/jira/browse/FLINK-35710 Project: Flink Issue T

Re: [VOTE] FLIP-444: Native file copy support

+1(binding) Best, Rui On Wed, Jun 26, 2024 at 10:22 PM Stefan Richter wrote: > > +1 (binding) > > Best, > Stefan > > > > > On 26. Jun 2024, at 16:14, Hong wrote: > > > > +1 (binding) > > > > Hong > > > >> On 26 Jun 2024, at 12:27, Keith Lee > wrote: > >> >

[jira] [Created] (FLINK-35709) Allow reordering source column names in CTAS / RTAS

Sergio Peña created FLINK-35709: --- Summary: Allow reordering source column names in CTAS / RTAS Key: FLINK-35709 URL: https://issues.apache.org/jira/browse/FLINK-35709 Project: Flink Issue Type:

[jira] [Created] (FLINK-35708) Allow defining a schema in REPLACE TABLE AS (RTAS)

Sergio Peña created FLINK-35708: --- Summary: Allow defining a schema in REPLACE TABLE AS (RTAS) Key: FLINK-35708 URL: https://issues.apache.org/jira/browse/FLINK-35708 Project: Flink Issue Type:

[jira] [Created] (FLINK-35707) Allow column definition in CREATE TABLE AS (CTAS)

Sergio Peña created FLINK-35707: --- Summary: Allow column definition in CREATE TABLE AS (CTAS) Key: FLINK-35707 URL: https://issues.apache.org/jira/browse/FLINK-35707 Project: Flink Issue Type: S

[jira] [Created] (FLINK-35706) FLIP-463: Schema Definition in CREATE TABLE AS Statement

Sergio Peña created FLINK-35706: --- Summary: FLIP-463: Schema Definition in CREATE TABLE AS Statement Key: FLINK-35706 URL: https://issues.apache.org/jira/browse/FLINK-35706 Project: Flink Issue

[RESULT][VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement

Hi everyone, the vote [1] for FLIP-463 [2] is over. The number of required binding votes (3) was reached (total: 8, binding: 3, non-binding: 5). Binding - Timo Walther - Sergey Nuyanzin - Martijn Visser Non-binding - Ferenc Csaky - Jeyhun Karimov - Jim Hughes - Yanquan Lv - Zhongqiang Gong There

[DISCUSS] CLI action deprecation process

Hello devs, I would like to open a discussion about considerations regarding how to deprecate CLI actions, and what compatibility guarantees should apply to such cases. The topic came up in a previous discussion [1] about a current FLIP to merge the run and run-application behavior [2]. Accordi

Re: [VOTE] FLIP-444: Native file copy support

+1 (binding) Best, Stefan > On 26. Jun 2024, at 16:14, Hong wrote: > > +1 (binding) > > Hong > >> On 26 Jun 2024, at 12:27, Keith Lee > > wrote: >> >> +1 (non binding) >> >> Best regards >> Keith Lee >> >> >>> On Wed, Jun 26, 2024 at 9:48 AM Zakelly

Re: [VOTE] FLIP-444: Native file copy support

+1 (binding) Hong > On 26 Jun 2024, at 12:27, Keith Lee wrote: > > +1 (non binding) > > Best regards > Keith Lee > > >> On Wed, Jun 26, 2024 at 9:48 AM Zakelly Lan wrote: >> +1 (binding) >> Best, >> Zakelly >>> On Wed, Jun 26, 2024 at 3:54 PM Yuepeng Pan wrote: >>> +1 (non-binding) >>> B

[jira] [Created] (FLINK-35705) Use region from stream ARN to construct SDK client

Aleksandr Pilipenko created FLINK-35705: --- Summary: Use region from stream ARN to construct SDK client Key: FLINK-35705 URL: https://issues.apache.org/jira/browse/FLINK-35705 Project: Flink

[jira] [Created] (FLINK-35704) ForkJoinPool introduction to NonSplittingRecursiveEnumerator to vastly improve enumeration performance

Grzegorz Liter created FLINK-35704: -- Summary: ForkJoinPool introduction to NonSplittingRecursiveEnumerator to vastly improve enumeration performance Key: FLINK-35704 URL: https://issues.apache.org/jira/browse/FLI

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

Hi devs, I'm proposing a new FLIP[1] to introduce the ProcessFunction Attribute in the DataStream API V2. The goal is to optimize job execution by leveraging additional information about users' ProcessFunction logic. The proposal includes the following scenarios where the ProcessFunction Attrib

Re: [VOTE] FLIP-444: Native file copy support

+1 (non binding) Best regards Keith Lee On Wed, Jun 26, 2024 at 9:48 AM Zakelly Lan wrote: > +1 (binding) > > > Best, > Zakelly > > On Wed, Jun 26, 2024 at 3:54 PM Yuepeng Pan wrote: > > > +1 (non-binding) > > > > > > > > > > Best regards, > > > > Yuepeng Pan > > > > > > > > > > > > > > > > >

[jira] [Created] (FLINK-35703) Nested comments in CREAT TABLE are lost

Dawid Wysakowicz created FLINK-35703: Summary: Nested comments in CREAT TABLE are lost Key: FLINK-35703 URL: https://issues.apache.org/jira/browse/FLINK-35703 Project: Flink Issue Type: B

Broken links to flink-training repository in documentation

Hi all, Some of the pages under the "Learn Flink" section of Flink documentation contain links to apache/flink-training repository [1]. This repository have not been updated since Flink 1.17 release, resulting in documentation for Flink 1.18 onwards pointing to not existing resources[2]. Should t

Re: [2.0] How to handle on-going feature development in Flink 2.0?

+1 for a preview before the formal release. It would help us find issues in advance. Best, Zakelly On Wed, Jun 26, 2024 at 4:44 PM Jingsong Li wrote: > +1 to release a preview version. > > Best, > Jingsong > > On Wed, Jun 26, 2024 at 10:12 AM Jark Wu wrote: > > > > I also think this should no

Re: [VOTE] FLIP-444: Native file copy support

+1 (binding) Best, Zakelly On Wed, Jun 26, 2024 at 3:54 PM Yuepeng Pan wrote: > +1 (non-binding) > > > > > Best regards, > > Yuepeng Pan > > > > > > > > > > > At 2024-06-26 15:27:17, "Piotr Nowojski" wrote: > >Thanks for pointing this out Zakelly. After the discussion on the dev > >mailing li

Re: [2.0] How to handle on-going feature development in Flink 2.0?

+1 to release a preview version. Best, Jingsong On Wed, Jun 26, 2024 at 10:12 AM Jark Wu wrote: > > I also think this should not block new feature development. > Having "nice-to-have" and "must-to-have" tags on the FLIPs is a good idea. > > For the downstream projects, I think we need to release

Re: [VOTE] FLIP-444: Native file copy support

+1 (non-binding) Best regards, Yuepeng Pan At 2024-06-26 15:27:17, "Piotr Nowojski" wrote: >Thanks for pointing this out Zakelly. After the discussion on the dev >mailing list, I have updated the `PathsCopyingFileSystem` to merge its >functionalities with `DuplicatingFileSystem`, bu

Re: [VOTE] FLIP-444: Native file copy support

+1 (binding) Thanks for pushing this and updating the FLIP Regards, Roman On Wed, Jun 26, 2024 at 9:27 AM Piotr Nowojski wrote: > Thanks for pointing this out Zakelly. After the discussion on the dev > mailing list, I have updated the `PathsCopyingFileSystem` to merge its > functionalities wi

Re: [VOTE] FLIP-444: Native file copy support

Thanks for pointing this out Zakelly. After the discussion on the dev mailing list, I have updated the `PathsCopyingFileSystem` to merge its functionalities with `DuplicatingFileSystem`, but I've just forgotten to mention that it will removed/replaced with `PathsCopyingFileSystem`. Vote can be res