[jira] [Created] (FLINK-31531) Test HiveCatalogHiveMetadataTest.testCreateTableWithConstraint failed on azure

Leonard Xu created FLINK-31531: -- Summary: Test HiveCatalogHiveMetadataTest.testCreateTableWithConstraint failed on azure Key: FLINK-31531 URL: https://issues.apache.org/jira/browse/FLINK-31531 Project:

[jira] [Created] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

xingyuan cheng created FLINK-31530: -- Summary: For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle Key: FLINK-31530 URL:

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1 (non-binding) Best, Hang 何军 于2023年3月21日周二 11:42写道： > +1 > > Leonard Xu 于2023年3月21日周二 11:35写道： > > > > > +1(binding) > > > > minor: The first SQL piece of the FLIP is incorrect as the column name > > current_time is a system built-in function. > > > > Best, > > Leonard > > > > > On Mar 21,

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1 Leonard Xu 于2023年3月21日周二 11:35写道： > > +1(binding) > > minor: The first SQL piece of the FLIP is incorrect as the column name > current_time is a system built-in function. > > Best, > Leonard > > > On Mar 21, 2023, at 9:38 AM, yuxia wrote: > > > > +1 (binding_ > > Thanks Kui for driving it.

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hi Panagiotis, Thanks for your proposal. It is valuable to analyze the reason for failure with the user plug-in. Making the context immutable could make the contract stronger. Letting the listener return an enriching result may be a better way. IIUC, listeners could do two things, enrich more

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1(binding) minor: The first SQL piece of the FLIP is incorrect as the column name current_time is a system built-in function. Best, Leonard > On Mar 21, 2023, at 9:38 AM, yuxia wrote: > > +1 (binding_ > Thanks Kui for driving it. > > Best regards, > Yuxia > > - 原始邮件 - > 发件人:

Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage

+1 (binding) Best Yun Tang From: Zhu Zhu Sent: Tuesday, March 21, 2023 10:07 To: dev@flink.apache.org Subject: Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage +1 (binding) Thanks, Zhu Xintong Song 于2023年3月20日周一 16:26写道： > > +1 (binding) > > Best,

Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage

+1 (binding) Thanks, Zhu Xintong Song 于2023年3月20日周一 16:26写道： > > +1 (binding) > > Best, > > Xintong > > > > On Mon, Mar 20, 2023 at 4:07 PM weijie guo > wrote: > > > Thanks Yuxin for driving this. > > > > +1 (binding) > > > > Best regards, > > > > Weijie > > > > > > Junrui Lee 于2023年3月20日周一

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1 (binding_ Thanks Kui for driving it. Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 发送时间: 星期二, 2023年 3 月 21日 上午 12:01:45 主题: Re: [VOTE] FLIP-296: Extend watermark-related features for SQL +1 binding Best regards, Jing On Mon, Mar 20, 2023 at 4:02 PM Jingsong Li wrote: >

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1 binding Best regards, Jing On Mon, Mar 20, 2023 at 4:02 PM Jingsong Li wrote: > +1 binding > > Jark Wu 于2023年3月20日 周一21:19写道： > > > +1 (binding) > > > > Best, > > Jark > > > > > 2023年3月15日 17:42，Yun Tang 写道： > > > > > > +1 (binding) > > > > > > Thanks Kui for driving this work. > > > > > >

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hi Panagiotis, Thanks for driving this. +1 for supporting custom restart strategy, we did receive such requests from the user mailing list [1][2]. Besides, in current design, the plugin will only do some statistical and classification work, and will not affect the *FailureHandlingResult*. Just

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1 binding Jark Wu 于2023年3月20日 周一21:19写道： > +1 (binding) > > Best, > Jark > > > 2023年3月15日 17:42，Yun Tang 写道： > > > > +1 (binding) > > > > Thanks Kui for driving this work. > > > > > > Best > > Yun Tang > > > > From: Kui Yuan > > Sent: Wednesday, March 15, 2023

Re: [VOTE] Release 1.17.0, release candidate #3

+1 (non-binding) - Verified signature - Verified hash - Build the source with Apple M1 chip. - Run streaming and batch job in sql-client successfully. - Build pyflink with M1 chip and run a pyflink job successfully. - Verified web PR Thanks Martijn and Matthias, Leonard and Qingsheng for driving

Re: [VOTE] Release 1.17.0, release candidate #3

+1 (binding) - Verified that the source release can be built successfully. - Verified that the checksum and gpg files match the corresponding source release files, binary release files, and maven artifacts. - Verified that the source archives do not contain any binary file. - Verified that all

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hi Panagiotis, Thanks for creating this proposal! It's good to enable Flink to handle different errors in different ways, through a pluggable way. There are requests for flexible restart strategies from time to time, for different strategies of restart backoff time, or to suppress restarting on

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1 (binding) Best, Jark > 2023年3月15日 17:42，Yun Tang 写道： > > +1 (binding) > > Thanks Kui for driving this work. > > > Best > Yun Tang > > From: Kui Yuan > Sent: Wednesday, March 15, 2023 16:45 > To: dev@flink.apache.org > Subject: [VOTE] FLIP-296: Extend

Re: [VOTE] Release 1.17.0, release candidate #3

+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR - Started a cluster and the Flink SQL client. Successfully connected with the Kafka connector to Confluent Cloud with

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hi Panagiotis Thank you for your answer. I agree that `FailureListener` could be stateless, then I have some thoughts as follows 1. I see that listeners and tag collections are associated. When JobManager fails and restarts, how can the new listener be associated with the tag collection before

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hi，Panagiotis Thank you for kicking off this discussion. Overall, the proposed feature of this FLIP makes sense to me. We have also discussed similar requirements with our users and developers, and I believe it will help many users. In terms of FLIP content, I have some thoughts: (1) For the

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

> > however listeners can use previous state (tags/labels) to make decisions That sounds like a very fragile contract. We should either allow passing tags between listeners and then need to define ordering or make all of them independent. I prefer the latter because it allows us to parallelize

Re: [VOTE] Release 1.17.0, release candidate #3

Hi Qingsheng, Hi Leonard, Thanks for sharing the info. IHMO, the watermark alignment should still be marked as beta, since the enhancement in 1.17 is far away from GA. I will leave a comment under FLINK-31519 . Let's stop here to let this thread

[jira] [Created] (FLINK-31529) Let yarn client exit early before JobManager running

Weihua Hu created FLINK-31529: - Summary: Let yarn client exit early before JobManager running Key: FLINK-31529 URL: https://issues.apache.org/jira/browse/FLINK-31529 Project: Flink Issue Type:

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

> + 1 (non-binding) > > Best, > Jiaba Hi, Jiabao Thanks for help to verify the release candidate. But we need to do the verification firstly and then post the verified items when in a release candidate vote thread. The community does not require verification of all items in the document

Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage

+1 (binding) Best, Xintong On Mon, Mar 20, 2023 at 4:07 PM weijie guo wrote: > Thanks Yuxin for driving this. > > +1 (binding) > > Best regards, > > Weijie > > > Junrui Lee 于2023年3月20日周一 14:57写道： > > > +1 (non-binding) > > > > Best regards, > > Junrui > > > > Weihua Hu 于2023年3月20日周一

Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage

Thanks Yuxin for driving this. +1 (binding) Best regards, Weijie Junrui Lee 于2023年3月20日周一 14:57写道： > +1 (non-binding) > > Best regards, > Junrui > > Weihua Hu 于2023年3月20日周一 14:24写道： > > > +1 (non-binding) > > > > Best, > > Weihua > > > > > > On Mon, Mar 20, 2023 at 12:39 PM Wencong Liu >

Re: [VOTE] Release 1.17.0, release candidate #3

+1 (non-binding) 1: Build from the source code 2: Verified the signature and checksum 3: Verified web PR 4: Run a SQL Job via Flink SQL Client Best regards, Yuxia - 原始邮件 - 发件人: "Leonard Xu" 收件人: "dev" 发送时间: 星期一, 2023年 3 月 20日 上午 11:19:01 主题: Re: [VOTE] Release 1.17.0, release candidate

[jira] [Created] (FLINK-31528) Move SqlCatalog* conversion logic to SqlNodeConverter

xuzhiwen created FLINK-31528: Summary: Move SqlCatalog* conversion logic to SqlNodeConverter Key: FLINK-31528 URL: https://issues.apache.org/jira/browse/FLINK-31528 Project: Flink Issue Type:

[jira] [Created] (FLINK-31527) ChangelogRescalingITCase.test failed due to FileNotFoundException

Matthias Pohl created FLINK-31527: - Summary: ChangelogRescalingITCase.test failed due to FileNotFoundException Key: FLINK-31527 URL: https://issues.apache.org/jira/browse/FLINK-31527 Project: Flink

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

Thanks Danny for driving this. + 1 (non-binding) Best, Jiabao > 2023年3月17日 上午4:32，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

[jira] [Created] (FLINK-31526) Various test failures in PyFlink

Matthias Pohl created FLINK-31526: - Summary: Various test failures in PyFlink Key: FLINK-31526 URL: https://issues.apache.org/jira/browse/FLINK-31526 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31525) JdbcExactlyOnceSinkE2eTest.testInsert times out

Matthias Pohl created FLINK-31525: - Summary: JdbcExactlyOnceSinkE2eTest.testInsert times out Key: FLINK-31525 URL: https://issues.apache.org/jira/browse/FLINK-31525 Project: Flink Issue

[jira] [Created] (FLINK-31524) StreamDependencyTests.test_add_python_file failed

Matthias Pohl created FLINK-31524: - Summary: StreamDependencyTests.test_add_python_file failed Key: FLINK-31524 URL: https://issues.apache.org/jira/browse/FLINK-31524 Project: Flink Issue

Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage

+1 (non-binding) Best regards, Junrui Weihua Hu 于2023年3月20日周一 14:24写道： > +1 (non-binding) > > Best, > Weihua > > > On Mon, Mar 20, 2023 at 12:39 PM Wencong Liu wrote: > > > +1 (non-binding) > > > > Best regards, > > > > Wencong Liu > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > >

[jira] [Created] (FLINK-31523) Merge query files and processing in sql client and gateway

Fang Yong created FLINK-31523: - Summary: Merge query files and processing in sql client and gateway Key: FLINK-31523 URL: https://issues.apache.org/jira/browse/FLINK-31523 Project: Flink Issue

[jira] [Created] (FLINK-31522) Introduce FlinkResultSet and related classes for jdbc driver

Fang Yong created FLINK-31522: - Summary: Introduce FlinkResultSet and related classes for jdbc driver Key: FLINK-31522 URL: https://issues.apache.org/jira/browse/FLINK-31522 Project: Flink

Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage

+1 (non-binding) Best, Weihua On Mon, Mar 20, 2023 at 12:39 PM Wencong Liu wrote: > +1 (non-binding) > > Best regards, > > Wencong Liu > > > > > > > > > > > > > > > > At 2023-03-20 12:05:47, "Yuxin Tan" wrote: > >Hi, everyone, > > > >Thanks for all your feedback for FLIP-301: Hybrid Shuffle

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hey David, Shammon, Thanks for the valuable comments! I am glad you find this proposal useful, some thoughts: @Shammon 1. How about adding more job information in FailureListenerContext? For > example, job vertext, subtask, taskmanager location. And then user can do > more statistics according

[jira] [Created] (FLINK-31521) Initialize flink jdbc driver module in flink-table

Fang Yong created FLINK-31521: - Summary: Initialize flink jdbc driver module in flink-table Key: FLINK-31521 URL: https://issues.apache.org/jira/browse/FLINK-31521 Project: Flink Issue Type:

Re: [VOTE] Release flink-connector-parent10.0, release candidate #1

+1 (nonbinding) - Verified hashes and signature - Verified git tag - Verified maven staging repo - Read Web PR Best, Mason On Thu, Mar 16, 2023 at 2:07 PM Tzu-Li (Gordon) Tai wrote: > +1 (binding) > > - Verified hashes and signature > - Read web PR > - Staging Maven artifacts