Re: [DISCUSS] FLIP-313 Add support of User Defined AsyncTableFunction

2023-06-13 Thread Lincoln Lee
Hi Aitozi, Sorry for the lately reply here! Supports async udtf(`AsyncTableFunction`) directly in sql seems like an attractive feature, but there're two issues that need to be addressed before we can be sure to add it: 1. As mentioned in the flip[1], the current lookup function can already implem

[jira] [Created] (FLINK-32333) The same SQL statement, sql-client and sql-gateway give different execution plans

2023-06-13 Thread macdoor615 (Jira)
macdoor615 created FLINK-32333: -- Summary: The same SQL statement, sql-client and sql-gateway give different execution plans Key: FLINK-32333 URL: https://issues.apache.org/jira/browse/FLINK-32333 Project

Re: Re: [VOTE] FLIP-311: Support Call Stored Procedure

2023-06-13 Thread Feng Jin
+1 (no-binding) Best, Feng On Wed, Jun 14, 2023 at 7:02 AM Jing Ge wrote: > +1(binding) > > Best Regards, > Jing > > On Tue, Jun 13, 2023 at 9:03 AM Mang Zhang wrote: > > > +1 (no-binding) > > > > > > > > > > -- > > > > Best regards, > > Mang Zhang > > > > > > > > > > > > 在 2023-06-13 13:19:

[VOTE] FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

2023-06-13 Thread Feng Jin
Hi everyone Thanks for all the feedback about the FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations[1]. [2] is the discussion thread. I'd like to start a vote for it. The vote will be open for at least 72 hours(excluding weekends,until June 19, 10:00AM G

[jira] [Created] (FLINK-32332) Jar files for catalog function are not listed correctly

2023-06-13 Thread Fang Yong (Jira)
Fang Yong created FLINK-32332: - Summary: Jar files for catalog function are not listed correctly Key: FLINK-32332 URL: https://issues.apache.org/jira/browse/FLINK-32332 Project: Flink Issue Type:

[VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

2023-06-13 Thread Aitozi
Hi all, Thanks for all the feedback about FLIP-313: Add support of User Defined AsyncTableFunction[1]. Based on the discussion [2], we have come to a consensus, so I would like to start a vote. The vote will be open for at least 72 hours (until June 19th, 10:00AM GMT) unless there is an objecti

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

2023-06-13 Thread yuxia
Yes, you're right. Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 发送时间: 星期三, 2023年 6 月 14日 上午 4:46:58 主题: Re: [DISCUSS] FLIP-311: Support Call Stored Procedure Hi yuxia, Thanks for your proposal and sorry for the late reply. The FLIP is in good shape. If I am not mistaken, Eve

Re: Re: [VOTE] FLIP-311: Support Call Stored Procedure

2023-06-13 Thread Jing Ge
+1(binding) Best Regards, Jing On Tue, Jun 13, 2023 at 9:03 AM Mang Zhang wrote: > +1 (no-binding) > > > > > -- > > Best regards, > Mang Zhang > > > > > > 在 2023-06-13 13:19:31,"Lincoln Lee" 写道: > >+1 (binding) > > > >Best, > >Lincoln Lee > > > > > >Jingsong Li 于2023年6月13日周二 10:07写道: > > > >>

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

2023-06-13 Thread Jing Ge
Hi yuxia, Thanks for your proposal and sorry for the late reply. The FLIP is in good shape. If I am not mistaken, Everything, that a stored procedure could do, could also be done by a Flink job. The current stored procedure design is to empower Catalogs to provide users some commonly used logics/f

[jira] [Created] (FLINK-32331) Print JVM thread dumps when Github Actions workflow gets cancelled/times out

2023-06-13 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-32331: -- Summary: Print JVM thread dumps when Github Actions workflow gets cancelled/times out Key: FLINK-32331 URL: https://issues.apache.org/jira/browse/FLINK-32331 Proj

Re: [DISCUSS] FLIP-321: Introduce an API deprecation process

2023-06-13 Thread Jing Ge
> This is by design. Most of these are @Public APIs that we had to carry > around until Flink 2.0, because that was the initial guarantee that we > gave people. > True, I knew @Public APIs could not be removed before the next major release. I meant house cleaning without violation of these annotat

Re: [DISCUSS] FLIP-321: Introduce an API deprecation process

2023-06-13 Thread Becket Qin
Hi Chesnay and Stefan, Thanks for the feedback and sorry for the confusion about Public API deprecation. I just noticed that there was a mistake in the NOTES part for Public API due to a copy-paste error... I just fixed it. To clarify on the deprecation of "Public" APIs. The FLIP does not propos

[jira] [Created] (FLINK-32330) Setup Java 17 in e2e builds

2023-06-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32330: Summary: Setup Java 17 in e2e builds Key: FLINK-32330 URL: https://issues.apache.org/jira/browse/FLINK-32330 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32329) Do not overwrite env.java.opts.all in HA e2e test

2023-06-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32329: Summary: Do not overwrite env.java.opts.all in HA e2e test Key: FLINK-32329 URL: https://issues.apache.org/jira/browse/FLINK-32329 Project: Flink Iss

[jira] [Created] (FLINK-32328) Ensure surefire baseLine is picked up by IntelliJ

2023-06-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32328: Summary: Ensure surefire baseLine is picked up by IntelliJ Key: FLINK-32328 URL: https://issues.apache.org/jira/browse/FLINK-32328 Project: Flink Iss

[jira] [Created] (FLINK-32327) Python Kafka connector runs into strange NullPointerException

2023-06-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32327: Summary: Python Kafka connector runs into strange NullPointerException Key: FLINK-32327 URL: https://issues.apache.org/jira/browse/FLINK-32327 Project: Flink

Re: [DISCUSS] FLIP-322 Cooldown period for adaptive scheduler

2023-06-13 Thread Etienne Chauchot
Hi Yuxia, Thanks for your feedback. The number of potentially stacked operations depends on the configured length of the cooldown period. The proposition in the FLIP is to add a minimum delay between 2 scaling operations. But, indeed, an optimization could be to still stack the operations (t

Re: [DISCUSS] FLIP-321: Introduce an API deprecation process

2023-06-13 Thread Chesnay Schepler
On 13/06/2023 12:50, Jing Ge wrote: One major issue we have, afaiu, is caused by the lack of housekeeping/house cleaning, there are many APIs that were marked as deprecated a few years ago and still don't get removed. Some APIs should be easy to remove and others will need some more clear rules,

Re: [DISCUSS] FLIP-321: Introduce an API deprecation process

2023-06-13 Thread Stefan Richter
Hi Becket, > *1. What is the scope of public interfaces?* > We actually already have a definition of public interfaces in the FLIP[1] > wiki, it is basically anything that is sensible to the users, including > packages, classes, method signature and behavior (blocking v.s. > non-blocking, for ex

[jira] [Created] (FLINK-32326) Disable WAL in RocksDBWriteBatchWrapper by default

2023-06-13 Thread Stefan Richter (Jira)
Stefan Richter created FLINK-32326: -- Summary: Disable WAL in RocksDBWriteBatchWrapper by default Key: FLINK-32326 URL: https://issues.apache.org/jira/browse/FLINK-32326 Project: Flink Issue

Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener

2023-06-13 Thread Shammon FY
Hi all, Thanks for all the valuable feedback. If there's no further question or concern, I will start voting for FLIP-294 [1] later. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-294%3A+Support+Customized+Catalog+Modification+Listener Best, Shammon FY On Fri, Jun 9, 2023 at 9:07 A

Re: [DISCUSS] FLIP-321: Introduce an API deprecation process

2023-06-13 Thread Jing Ge
Hi Becket, Thanks for driving this important topic! There were many discussions previously that ended up with waiting up for a clear API deprecation process definition. This FLIP will help a lot. I'd like to ask some questions to understand your thoughts. Speaking of the FLIP, *"Always add a "S

Re: [DISCUSS] FLIP-321: Introduce an API deprecation process

2023-06-13 Thread Becket Qin
Hi Stefan, Thanks for the comments. I agree the API stability and compatibility guarantees should be clear. I think we need to answer the following four questions in order to complete the the public API stability and compatibility story: *1. What is the scope of public interfaces?* We actually al

[jira] [Created] (FLINK-32325) SqlServerDynamicTableSourceITCase is flaky

2023-06-13 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-32325: -- Summary: SqlServerDynamicTableSourceITCase is flaky Key: FLINK-32325 URL: https://issues.apache.org/jira/browse/FLINK-32325 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-32324) Implement watermark alignment on KDS source

2023-06-13 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32324: --- Summary: Implement watermark alignment on KDS source Key: FLINK-32324 URL: https://issues.apache.org/jira/browse/FLINK-32324 Project: Flink Issue Type:

[jira] [Created] (FLINK-32323) Flink Testing doc missing key information about dependency

2023-06-13 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-32323: Summary: Flink Testing doc missing key information about dependency Key: FLINK-32323 URL: https://issues.apache.org/jira/browse/FLINK-32323 Project: Flink Is

Re:Re: [VOTE] FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

2023-06-13 Thread Mang Zhang
+1 (no-binding) -- Best regards, Mang Zhang 在 2023-06-13 13:19:18,"Lincoln Lee" 写道: >+1 (binding) > >Best, >Lincoln Lee > > >Jingsong Li 于2023年6月13日周二 10:07写道: > >> +1 >> >> On Mon, Jun 12, 2023 at 10:25 PM Rui Fan <1996fan...@gmail.com> wrote: >> > >> > +1 (binding) >> > >> > Best, >>

Re:Re: [VOTE] FLIP-311: Support Call Stored Procedure

2023-06-13 Thread Mang Zhang
+1 (no-binding) -- Best regards, Mang Zhang 在 2023-06-13 13:19:31,"Lincoln Lee" 写道: >+1 (binding) > >Best, >Lincoln Lee > > >Jingsong Li 于2023年6月13日周二 10:07写道: > >> +1 >> >> On Mon, Jun 12, 2023 at 10:32 PM Rui Fan <1996fan...@gmail.com> wrote: >> > >> > +1 (binding) >> > >> > Best, >>