Re: [VOTE] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-27 Thread Zhu Zhu
+1 (binding) Thanks, Zhu Rui Fan <1996fan...@gmail.com> 于2023年11月28日周二 13:11写道: > +1(binding) > > Best, > Rui > > On Tue, Nov 28, 2023 at 12:34 PM Junrui Lee wrote: > > > Hi everyone, > > > > Thank you to everyone for the feedback on FLIP-391: Deprecate > > RuntimeContext#getExecutionConfig[1]

[jira] [Created] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-27 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-33670: - Summary: Public operators cannot be reused in multi sinks Key: FLINK-33670 URL: https://issues.apache.org/jira/browse/FLINK-33670 Project: Flink Issue Type:

[jira] [Created] (FLINK-33669) Update the documentation for RestartStrategy, Checkpoint Storage, and State Backend.

2023-11-27 Thread Junrui Li (Jira)
Junrui Li created FLINK-33669: - Summary: Update the documentation for RestartStrategy, Checkpoint Storage, and State Backend. Key: FLINK-33669 URL: https://issues.apache.org/jira/browse/FLINK-33669

Re: [VOTE] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-27 Thread Rui Fan
+1(binding) Best, Rui On Tue, Nov 28, 2023 at 12:34 PM Junrui Lee wrote: > Hi everyone, > > Thank you to everyone for the feedback on FLIP-391: Deprecate > RuntimeContext#getExecutionConfig[1] which has been discussed in this > thread [2]. > > I would like to start a vote for it. The vote will

[VOTE] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-27 Thread Junrui Lee
Hi everyone, Thank you to everyone for the feedback on FLIP-391: Deprecate RuntimeContext#getExecutionConfig[1] which has been discussed in this thread [2]. I would like to start a vote for it. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1]

[jira] [Created] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-27 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-33668: - Summary: Decoupling Shuffle network memory and job topology Key: FLINK-33668 URL: https://issues.apache.org/jira/browse/FLINK-33668 Project: Flink Issue Type:

[RESULT][VOTE] FLIP-378: Support Avro timestamp with local timezone

2023-11-27 Thread Peter Huang
Dear developers, FLIP-378 [1] has been accepted and voted through this thread [2]. The proposal received 6 approving votes, 5 of which are binding, and there is no disapproval. - Gyula Fora (binding) - Jark Wu (binding) - Jing Ge (binding) - Leonard Xu (binding) - Matyas Orhidi (binding) -

[jira] [Created] (FLINK-33667) Implement restore tests for MatchRecognize node

2023-11-27 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-33667: -- Summary: Implement restore tests for MatchRecognize node Key: FLINK-33667 URL: https://issues.apache.org/jira/browse/FLINK-33667 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-394: Add Metrics for Connector Agnostic Autoscaling

2023-11-27 Thread Mason Chen
Hi Leonard, Thanks for the review! See my responses below: 1. Let's take for example the case that a split is a file (i.e. what I call bounded). To calculate the pending records, the connector needs to know how many splits are left and the number of records in each split. If a reader only knows

Re: [DISCUSS] Resolve diamond inheritance of Sink.createWriter

2023-11-27 Thread Péter Váry
I think we should try to separate the discussion in a few different topics: - Concrete issue - How to solve this problem in 1.19 and wrt the affected createWriter interface - Update the documentation [1], so FLIP-321 is visible for every contributor - Generic issue

[jira] [Created] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

2023-11-27 Thread Timo Walther (Jira)
Timo Walther created FLINK-33666: Summary: MergeTableLikeUtil uses different constraint name than Schema Key: FLINK-33666 URL: https://issues.apache.org/jira/browse/FLINK-33666 Project: Flink

Python connector question

2023-11-27 Thread Péter Váry
Hi Team, During some, mostly unrelated work we come to realize that during the externalization of the connector's python modules and the related tests are not moved to the respective connectors repository. We created the jiras [1] to create the infra, and to move the python code and the tests to

Re: Re:Re: [DISCUSS][FLINK-32993] Datagen connector handles length-constrained fields according to the schema definition by default

2023-11-27 Thread Lincoln Lee
Hi Yubin, Thanks for the update! +1 for keeping the default length of String and Bytes unchange. Best, Lincoln Lee lixin58...@163.com 于2023年11月24日周五 12:04写道: > Thank Jane for providing examples to make discussions clearer. > Thank Lincoln and Xuyang for your feedback,I agree with you

Re: [DISCUSS] Contribute Flink Doris Connector to the Flink community

2023-11-27 Thread Martijn Visser
Hi di.wu, Thanks for the proposal, +1 Best regards, Martijn On Mon, Nov 27, 2023 at 1:05 PM Zhanghao Chen wrote: > > Sounds great. Thanks for driving this. > > Best, > Zhanghao Chen > > From: wudi <676366...@qq.com.INVALID> > Sent: Sunday, November 26, 2023

[jira] [Created] (FLINK-33665) Invalid code execution

2023-11-27 Thread Peihui He (Jira)
Peihui He created FLINK-33665: - Summary: Invalid code execution Key: FLINK-33665 URL: https://issues.apache.org/jira/browse/FLINK-33665 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Contribute Flink Doris Connector to the Flink community

2023-11-27 Thread Zhanghao Chen
Sounds great. Thanks for driving this. Best, Zhanghao Chen From: wudi <676366...@qq.com.INVALID> Sent: Sunday, November 26, 2023 18:22 To: dev@flink.apache.org Subject: [DISCUSS] Contribute Flink Doris Connector to the Flink community Hi all, At present, Flink

[DISCUSS] FLIP-397: Add config options for administrator JVM options

2023-11-27 Thread Zhanghao Chen
Hi devs, I'd like to start a discussion on FLIP-397: Add config options for administrator JVM options [1]. In production environments, users typically develop and operate their Flink jobs through a managed platform. Users may need to add JVM options to their Flink applications (e.g. to tune

[RESULT] [VOTE] Release 1.17.2, release candidate #1

2023-11-27 Thread Yun Tang
I'm happy to announce that we have unanimously approved this release. There are 13 approving votes, 4 of which are binding: - Rui Fan - Matthias Pohl (binding) - Danny Cranmer (binding) - Leonard Xu (binding) - Sergey Nuyanzin - Jiabao Sun - Hang Ruan - Feng Jin - Yuxin Tan - Weijie Guo - Jing

[jira] [Created] (FLINK-33664) Setup cron build for java 21

2023-11-27 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33664: --- Summary: Setup cron build for java 21 Key: FLINK-33664 URL: https://issues.apache.org/jira/browse/FLINK-33664 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Contribute Flink Doris Connector to the Flink community

2023-11-27 Thread Etienne Chauchot
+1 as well Best Etienne Le 27/11/2023 à 06:22, Jing Ge a écrit : That sounds great! +1 Best regards Jing On Mon, Nov 27, 2023 at 3:38 AM Leonard Xu wrote: Thanks wudi for kicking off the discussion, +1 for the idea from my side. A FLIP like Yun posted is required if no other

Re: Sending a hi!

2023-11-27 Thread Etienne Chauchot
Welcome to the community Pranav ! Best Etienne Le 25/11/2023 à 17:59, Pranav Sharma a écrit : Hi everyone, I am Pranav, and I am getting started to contribute to the Apache Flink project. I have been previously contributing to another Apache project, Allura. I came across flink during my

Re: [DISCUSSION] flink-connector-shared-utils release process

2023-11-27 Thread Etienne Chauchot
Sure! Le 23/11/2023 à 02:57, Leonard Xu a écrit : Thanks Etienne for driving this. - a flink-connector-shared-utils-*test* clone repo and a *io.github.user.flink*:flink-connector-parent custom artifact to be able to directly commit and install the artifact in the CI - a custom ci script

[jira] [Created] (FLINK-33663) Serialize CallExpressions into SQL

2023-11-27 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33663: Summary: Serialize CallExpressions into SQL Key: FLINK-33663 URL: https://issues.apache.org/jira/browse/FLINK-33663 Project: Flink Issue Type:

[DISCUSS] Resolve diamond inheritance of Sink.createWriter

2023-11-27 Thread Martijn Visser
Hi all, I'm opening this discussion thread to bring a discussion that's happening on a completed Jira ticket back to the mailing list [1] In summary: * There was a discussion and a vote on FLIP-371 [2] * During implementation, it was determined that there's a diamond inheritance problem on the

[jira] [Created] (FLINK-33662) Bump com.h2database:h2

2023-11-27 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33662: -- Summary: Bump com.h2database:h2 Key: FLINK-33662 URL: https://issues.apache.org/jira/browse/FLINK-33662 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-33661) 'RocksDB Memory Management end-to-end test' failed due to unexpected error in logs

2023-11-27 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33661: - Summary: 'RocksDB Memory Management end-to-end test' failed due to unexpected error in logs Key: FLINK-33661 URL: https://issues.apache.org/jira/browse/FLINK-33661

[jira] [Created] (FLINK-33660) AggregateITCase.testConstantGroupKeyWithUpsertSink due to unexpected behavior

2023-11-27 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33660: - Summary: AggregateITCase.testConstantGroupKeyWithUpsertSink due to unexpected behavior Key: FLINK-33660 URL: https://issues.apache.org/jira/browse/FLINK-33660

[jira] [Created] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

2023-11-27 Thread zhouli (Jira)
zhouli created FLINK-33659: -- Summary: Avoid unnecessary retries when restore from savepoint failed. Key: FLINK-33659 URL: https://issues.apache.org/jira/browse/FLINK-33659 Project: Flink Issue

[jira] [Created] (FLINK-33658) Hosted runner lost communication

2023-11-27 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33658: - Summary: Hosted runner lost communication Key: FLINK-33658 URL: https://issues.apache.org/jira/browse/FLINK-33658 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33657) Insert message in top n without row number didn't consider it's number and may not correct

2023-11-27 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-33657: --- Summary: Insert message in top n without row number didn't consider it's number and may not correct Key: FLINK-33657 URL: https://issues.apache.org/jira/browse/FLINK-33657

Re: [VOTE] Apache Flink Kafka Connectors v3.0.2, RC #1

2023-11-27 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PRs On Mon, Nov 27, 2023 at 4:17 AM Leonard Xu wrote: > > +1 (binding) > > - checked the flink-connector-base dependency