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

2023-06-12 Thread 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, > > Rui Fan > > > > On Mon, Jun 12, 2023 at 19:58 liu ron wrote: > > > > > +1 (no-binding) > > > > > > Best, >

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

2023-06-12 Thread 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, > > Rui Fan > > > > On Mon, Jun 12, 2023 at 22:20 Benchao Li wrote: > > > > > +1 (binding) > > > > > > yuxia

[jira] [Created] (FLINK-32321) Temporal Join job missing condition after “ON”

2023-06-12 Thread macdoor615 (Jira)
macdoor615 created FLINK-32321: -- Summary: Temporal Join job missing condition after “ON” Key: FLINK-32321 URL: https://issues.apache.org/jira/browse/FLINK-32321 Project: Flink Issue Type: Bug

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

2023-06-12 Thread Aitozi
Get your meaning now, thanks :) Best, Aitozi. Feng Jin 于2023年6月13日周二 11:16写道: > Hi Aitozi, > > Sorry for the confusing description. > > What I meant was that if we need to remind users about tire safety issues, > we should introduce the new UDTF interface instead of executing the > original

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

2023-06-12 Thread Feng Jin
Hi Aitozi, Sorry for the confusing description. What I meant was that if we need to remind users about tire safety issues, we should introduce the new UDTF interface instead of executing the original UDTF asynchronously. Therefore, I agree with introducing the AsyncTableFunction. Best, Feng On

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

2023-06-12 Thread Aitozi
Hi Feng, Thanks for your question. We do not provide a way to switch the UDTF between sync and async way, So there should be no thread safety problem here. Best, Aitozi Feng Jin 于2023年6月13日周二 10:31写道: > Hi Aitozi, We do need to remind users about thread safety issues. Thank you > for your

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

2023-06-12 Thread Feng Jin
Hi Aitozi, We do need to remind users about thread safety issues. Thank you for your efforts on this FLIP. I have no further questions. Best, Feng On Tue, Jun 13, 2023 at 6:05 AM Jing Ge wrote: > Hi Aitozi, > > Thanks for taking care of that part. I have no other concern. > > Best regards, >

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

2023-06-12 Thread yuxia
Hi, Etienne. Thanks for driving it. I have one question about the mechanism of the cooldown timeout. >From the Proposed Changes part, if a scalling event is received and it falls >during the cooldown period, it'll be stacked to be executed after the period >ends. Also, from the description of

[jira] [Created] (FLINK-32320) Same correlate can not be reused due to the different correlationId

2023-06-12 Thread Aitozi (Jira)
Aitozi created FLINK-32320: -- Summary: Same correlate can not be reused due to the different correlationId Key: FLINK-32320 URL: https://issues.apache.org/jira/browse/FLINK-32320 Project: Flink

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

2023-06-12 Thread Jingsong Li
+1 On Mon, Jun 12, 2023 at 10:25 PM Rui Fan <1996fan...@gmail.com> wrote: > > +1 (binding) > > Best, > Rui Fan > > On Mon, Jun 12, 2023 at 19:58 liu ron wrote: > > > +1 (no-binding) > > > > Best, > > Ron > > > > Jing Ge 于2023年6月12日周一 19:33写道: > > > > > +1(binding) Thanks! > > > > > > Best

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

2023-06-12 Thread Jingsong Li
+1 On Mon, Jun 12, 2023 at 10:32 PM Rui Fan <1996fan...@gmail.com> wrote: > > +1 (binding) > > Best, > Rui Fan > > On Mon, Jun 12, 2023 at 22:20 Benchao Li wrote: > > > +1 (binding) > > > > yuxia 于2023年6月12日周一 17:58写道: > > > > > Hi everyone, > > > Thanks for all the feedback about FLIP-311:

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

2023-06-12 Thread Feng Jin
Hi everyone, Thank you everyone for your valuable input. If there are no further questions or concerns about the FLIP-295[1], I would like to start voting tomorrow (6/14). [1]

[jira] [Created] (FLINK-32319) flink can't the partition of network after restart

2023-06-12 Thread wgcn (Jira)
wgcn created FLINK-32319: Summary: flink can't the partition of network after restart Key: FLINK-32319 URL: https://issues.apache.org/jira/browse/FLINK-32319 Project: Flink Issue Type: Bug

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

2023-06-12 Thread Jing Ge
Hi Aitozi, Thanks for taking care of that part. I have no other concern. Best regards, Jing On Mon, Jun 12, 2023 at 5:38 PM Aitozi wrote: > BTW, If there are no other more blocking issue / comments, I would like to > start a VOTE in another thread this wednesday 6.14 > > Thanks, > Aitozi. >

Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

2023-06-12 Thread Mason Chen
> > My main worry for doing this as a later iteration is that this would > probably be a breaking change for the public interface. If that can be > avoided and planned ahead, I'm fine with moving forward with how it is > right now. Make sense. Considering the public interfaces, I think we still

[jira] [Created] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-12 Thread Jira
Luís Costa created FLINK-32318: -- Summary: [flink-operator] missing s3 plugin in folder plugins Key: FLINK-32318 URL: https://issues.apache.org/jira/browse/FLINK-32318 Project: Flink Issue Type:

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

2023-06-12 Thread Stefan Richter
Hi, Thanks a lot for bringing up this topic and for the initial proposal. As more and more people are looking into running Flink as a continuous service this discussion is becoming very relevant. What I would like to see is a clearer definition for what we understand by stability and

[jira] [Created] (FLINK-32317) Enrich metadata in CR error field

2023-06-12 Thread Daren Wong (Jira)
Daren Wong created FLINK-32317: -- Summary: Enrich metadata in CR error field Key: FLINK-32317 URL: https://issues.apache.org/jira/browse/FLINK-32317 Project: Flink Issue Type: Improvement

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

2023-06-12 Thread Aitozi
BTW, If there are no other more blocking issue / comments, I would like to start a VOTE in another thread this wednesday 6.14 Thanks, Aitozi. Aitozi 于2023年6月12日周一 23:34写道: > Hi, Jing, > Thanks for your explanation. I get your point now. > > For the performance part, I think it's a good

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

2023-06-12 Thread Aitozi
Hi, Jing, Thanks for your explanation. I get your point now. For the performance part, I think it's a good idea to run with returning a big table case, the memory consumption should be a point to be taken care about. Because in the ordered mode, the head element in buffer may affect the total

[DISCUSS] FLIP-322 Cooldown period for adaptive scheduler

2023-06-12 Thread Etienne Chauchot
Hi, I’d like to start a discussion about FLIP-322 [1] which introduces a cooldown period for the adaptive scheduler. I'd like to get your feedback especially @Robert as you opened the related ticket and worked on the reactive mode a lot. [1]

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

2023-06-12 Thread Rui Fan
+1 (binding) Best, Rui Fan On Mon, Jun 12, 2023 at 22:20 Benchao Li wrote: > +1 (binding) > > yuxia 于2023年6月12日周一 17:58写道: > > > Hi everyone, > > Thanks for all the feedback about FLIP-311: Support Call Stored > > Procedure[1]. Based on the discussion [2], we have come to a consensus, > so >

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

2023-06-12 Thread Rui Fan
+1 (binding) Best, Rui Fan On Mon, Jun 12, 2023 at 19:58 liu ron wrote: > +1 (no-binding) > > Best, > Ron > > Jing Ge 于2023年6月12日周一 19:33写道: > > > +1(binding) Thanks! > > > > Best regards, > > Jing > > > > On Mon, Jun 12, 2023 at 12:01 PM yuxia > > wrote: > > > > > +1 (binding) > > > Thanks

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

2023-06-12 Thread Benchao Li
+1 (binding) yuxia 于2023年6月12日周一 17:58写道: > Hi everyone, > Thanks for all the feedback about FLIP-311: Support Call Stored > Procedure[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 15th,

[jira] [Created] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

2023-06-12 Thread Cai Liuyang (Jira)
Cai Liuyang created FLINK-32316: --- Summary: Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover Key: FLINK-32316 URL: https://issues.apache.org/jira/browse/FLINK-32316

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

2023-06-12 Thread Paul Lam
Hi Yang, Thanks a lot for your input! It’s great that FLINK-28915 has covered the file download part. I’ve created a ticket for the file upload part [1]. It's a prerequisite for supporting K8s application mode for SQL Gateway. [1] https://issues.apache.org/jira/browse/FLINK-32315 Best, Paul

[jira] [Created] (FLINK-32315) Support local file upload in K8s mode

2023-06-12 Thread Paul Lin (Jira)
Paul Lin created FLINK-32315: Summary: Support local file upload in K8s mode Key: FLINK-32315 URL: https://issues.apache.org/jira/browse/FLINK-32315 Project: Flink Issue Type: New Feature

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

2023-06-12 Thread Jing Ge
Hi Aitozi, Which key will be used for lookup is not an issue, only one row will be required for each key in order to enrich it. True, it depends on the implementation whether multiple rows or single row for each key will be returned. However, for the lookup & enrichment scenario, one row/key is

[jira] [Created] (FLINK-32314) Ignore class-loading errors after RPC system shutdown

2023-06-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32314: Summary: Ignore class-loading errors after RPC system shutdown Key: FLINK-32314 URL: https://issues.apache.org/jira/browse/FLINK-32314 Project: Flink

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

2023-06-12 Thread liu ron
+1 (no-binding) Best, Ron Jing Ge 于2023年6月12日周一 19:33写道: > +1(binding) Thanks! > > Best regards, > Jing > > On Mon, Jun 12, 2023 at 12:01 PM yuxia > wrote: > > > +1 (binding) > > Thanks Mang driving it. > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "zhangmang1" > > 收件人:

[jira] [Created] (FLINK-32313) CrateDB relies on flink-shaded in flink-connector-jdbc

2023-06-12 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-32313: -- Summary: CrateDB relies on flink-shaded in flink-connector-jdbc Key: FLINK-32313 URL: https://issues.apache.org/jira/browse/FLINK-32313 Project: Flink

[jira] [Created] (FLINK-32312) SSLConnectionSocketFactory produced no output for 900 seconds

2023-06-12 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32312: --- Summary: SSLConnectionSocketFactory produced no output for 900 seconds Key: FLINK-32312 URL: https://issues.apache.org/jira/browse/FLINK-32312 Project: Flink

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

2023-06-12 Thread Jing Ge
+1(binding) Thanks! Best regards, Jing On Mon, Jun 12, 2023 at 12:01 PM yuxia wrote: > +1 (binding) > Thanks Mang driving it. > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "zhangmang1" > 收件人: "dev" > 发送时间: 星期一, 2023年 6 月 12日 下午 5:31:10 > 主题: [VOTE] FLIP-305: Support atomic for CREATE

[jira] [Created] (FLINK-32311) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock

2023-06-12 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32311: --- Summary: ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock Key: FLINK-32311 URL:

[jira] [Created] (FLINK-32310) Support enhanced show functions syntax

2023-06-12 Thread Ran Tao (Jira)
Ran Tao created FLINK-32310: --- Summary: Support enhanced show functions syntax Key: FLINK-32310 URL: https://issues.apache.org/jira/browse/FLINK-32310 Project: Flink Issue Type: Improvement

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

2023-06-12 Thread yuxia
+1 (binding) Thanks Mang driving it. Best regards, Yuxia - 原始邮件 - 发件人: "zhangmang1" 收件人: "dev" 发送时间: 星期一, 2023年 6 月 12日 下午 5:31:10 主题: [VOTE] FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement Hi everyone, Thanks for all the feedback about FLIP-305: Support atomic

[VOTE] FLIP-311: Support Call Stored Procedure

2023-06-12 Thread yuxia
Hi everyone, Thanks for all the feedback about FLIP-311: Support Call Stored Procedure[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 15th, 10:00AM GMT) unless there is an objection or an

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

2023-06-12 Thread Mang Zhang
Hi everyone, Thanks for all the feedback about FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement[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 (until June 15th, 10:00AM GMT) unless there is an objection or an

[jira] [Created] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

2023-06-12 Thread Fang Yong (Jira)
Fang Yong created FLINK-32309: - Summary: Shared classpaths and jars manager for jobs in sql gateway cause confliction Key: FLINK-32309 URL: https://issues.apache.org/jira/browse/FLINK-32309 Project:

[jira] [Created] (FLINK-32308) RestClusterClient submit job to remote cluster

2023-06-12 Thread Spongebob (Jira)
Spongebob created FLINK-32308: - Summary: RestClusterClient submit job to remote cluster Key: FLINK-32308 URL: https://issues.apache.org/jira/browse/FLINK-32308 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32307) Incorrect docs for default behavior of "scan.startup.mode" option

2023-06-12 Thread Gunnar Morling (Jira)
Gunnar Morling created FLINK-32307: -- Summary: Incorrect docs for default behavior of "scan.startup.mode" option Key: FLINK-32307 URL: https://issues.apache.org/jira/browse/FLINK-32307 Project: Flink

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

2023-06-12 Thread Shengkai Fang
> If it’s the case, I’m good with introducing a new module and making SQL Driver > an internal class and accepts JSON plans only. I rethink this again and again. I think it's better to move the SqlDriver into the sql-gateway module because the sql client relies on the sql-gateway to submit the

Re: [VOTE] FLIP-315: Support Operator Fusion Codegen for Flink SQL

2023-06-12 Thread liu ron
Hi, all. FLIP-315 [1] has been accepted. There are 5 binding votes, 1 non-binding votes: - Jark Wu(binding) - Jingsong Li (binding) - Benchao Li (binding) - Weijie Guo(binding) - Jing Ge(binding) - Aitozi (non-binding) Thanks everyone. [1]