Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project

2025-06-04 Thread Feng Jin
+1 (binding) Best, Feng Jin On Wed, Jun 4, 2025 at 1:51 PM Yun Tang wrote: > +1 (binding) > > > Best, > Yun Tang > > From: Gustavo de Morais > Sent: Wednesday, June 4, 2025 0:25 > To: dev@flink.apache.org > Subject: Re: [VOTE] F

Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin

2025-05-11 Thread Feng Jin
Hi, xuyang Thanks for proposing this FLIP — it’s very helpful for scenarios involving large states. I have a few questions regarding the node whitelist section: 1. If the TableSource implements FilterPushdownSpec, take LEFT JOIN as an example — when the right side supports filter pushdown, the s

Re: [ANNOUNCE] New Apache Flink Committer - Yanquan Lv

2025-04-18 Thread Feng Jin
Congratulations! Best, Feng Jin On Fri, Apr 18, 2025 at 2:13 PM Sergey Nuyanzin wrote: > Congratulations! > > On Fri, Apr 18, 2025, 05:59 Hang Ruan wrote: > > > Congrats Yanquan! > > > > Best, > > Hang > > > > On Fri,

Re: [ANNOUNCE] New Apache Flink Committer - Xiqian Yu

2025-04-17 Thread Feng Jin
Congratulations! Best, Feng Jin On Fri, Apr 18, 2025 at 2:13 PM Sergey Nuyanzin wrote: > Congratulations! > > On Fri, Apr 18, 2025, 06:00 Hang Ruan wrote: > > > Congratulations! > > > > Best, > > Hang > > > > On Fri, Apr 18, 2025 at 11:21 AM Yue

Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history

2025-03-27 Thread Feng Jin
+1 (binding) Best, Feng On Wed, Mar 26, 2025 at 2:07 PM Wei Zhong wrote: > +1 (binding) > > Best, > Wei > > > 2025年3月25日 17:50,Yuepeng Pan 写道: > > > > Hi all, Thanks for all the feedback on FLIP-495[1][2]. I'd like to start > a vote for FLIP-495. The vote will last for at least 72 hours unles

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-20 Thread Feng Jin
Congratulations, Xuyang! Best, Feng Jin On Thu, Feb 20, 2025 at 5:44 PM gongzhongqiang wrote: > Congratulations, Xuyang! > > > Best, > Zhongqiang Gong > > Lincoln Lee 于2025年2月20日周四 09:50写道: > > > Hi everyone, > > > > On behalf of the PMC, I&#x

[jira] [Created] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException

2025-02-17 Thread Feng Jin (Jira)
Feng Jin created FLINK-37337: Summary: Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException Key: FLINK-37337 URL: https://issues.apache.org/jira/browse/FLINK-37337

[jira] [Created] (FLINK-37188) Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s"

2025-01-20 Thread Feng Jin (Jira)
Feng Jin created FLINK-37188: Summary: Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s" Key: FLINK-37188 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-37187) Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s

2025-01-20 Thread Feng Jin (Jira)
Feng Jin created FLINK-37187: Summary: Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s Key: FLINK-37187 URL: https://issues.apache.org/jira/browse/FLINK-37187 Project: Flink

[jira] [Created] (FLINK-37134) Cross-team verification for FLIP-492

2025-01-15 Thread Feng Jin (Jira)
Feng Jin created FLINK-37134: Summary: Cross-team verification for FLIP-492 Key: FLINK-37134 URL: https://issues.apache.org/jira/browse/FLINK-37134 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37133) Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s

2025-01-14 Thread Feng Jin (Jira)
Feng Jin created FLINK-37133: Summary: Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s Key: FLINK-37133 URL: https://issues.apache.org/jira/browse/FLINK-37133 Project: Flink

[jira] [Created] (FLINK-37066) Add Pre-check for Definition Query During Creation or Query Modification of Materialized Table

2025-01-08 Thread Feng Jin (Jira)
Feng Jin created FLINK-37066: Summary: Add Pre-check for Definition Query During Creation or Query Modification of Materialized Table Key: FLINK-37066 URL: https://issues.apache.org/jira/browse/FLINK-37066

[jira] [Created] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query

2025-01-08 Thread Feng Jin (Jira)
Feng Jin created FLINK-37064: Summary: Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Key: FLINK-37064 URL: https://issues.apache.org/jira/browse/FLINK

Re: Re:[DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed

2025-01-02 Thread Feng Jin
+1 Directly remove the default implementation, as this allows issues to be detected at compile time rather than at runtime. Even if we keep these methods, it doesn’t seem to make much sense. Best, Feng Jin On Fri, Jan 3, 2025 at 12:57 PM Xuyang wrote: > +1 to delete the overrided defa

[jira] [Created] (FLINK-36995) Support REPLACE MATERIALIZED TABLE AS statement

2025-01-02 Thread Feng Jin (Jira)
Feng Jin created FLINK-36995: Summary: Support REPLACE MATERIALIZED TABLE AS statement Key: FLINK-36995 URL: https://issues.apache.org/jira/browse/FLINK-36995 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36994) Support Alter Materialized Table As Query

2025-01-02 Thread Feng Jin (Jira)
Feng Jin created FLINK-36994: Summary: Support Alter Materialized Table As Query Key: FLINK-36994 URL: https://issues.apache.org/jira/browse/FLINK-36994 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36993) FLIP-492: Support Query Modifications for Materialized Tables

2025-01-02 Thread Feng Jin (Jira)
Feng Jin created FLINK-36993: Summary: FLIP-492: Support Query Modifications for Materialized Tables Key: FLINK-36993 URL: https://issues.apache.org/jira/browse/FLINK-36993 Project: Flink Issue

[RESULT][VOTE] FLIP-492: Support Query Modifications for Materialized Tables

2025-01-01 Thread Feng Jin
g [1]. https://cwiki.apache.org/confluence/display/FLINK/FLIP-492%3A+Support+Query+Modifications+for+Materialized+Tables [2]. https://lists.apache.org/thread/4zd0zho160mmx36h1m2gm26dm2nssfmw Best, Feng Jin

Re: Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables

2025-01-01 Thread Feng Jin
Hi everyone, Thank you all for voting. I believe we have enough votes now. The results will be sent out in a separate email. Best, Feng Jin On Thu, Jan 2, 2025 at 11:05 AM Xuyang wrote: > +1 (non-binding) > > > -- > > Best! > Xuyang > > > > > &g

[VOTE] FLIP-492: Support Query Modifications for Materialized Tables

2024-12-29 Thread Feng Jin
splay/FLINK/FLIP-492%3A+Support+Query+Modifications+for+Materialized+Tables [2]. https://lists.apache.org/thread/bvgtdwfbnlq5j5lb97dzyj66dlxt5mng Best, Feng Jin

Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.

2024-12-25 Thread Feng Jin
Hi, everyone, The discussion has not received any responses for a while. If there are no further comments this week, I will close the discussion and initiate the vote next Monday. Thank you all for your input! Best regards, Feng Jin On Fri, Dec 20, 2024 at 10:38 AM Feng Jin wrote: >

Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment

2024-12-23 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Tue, Dec 24, 2024 at 10:42 AM Yuepeng Pan wrote: > +1 (non-binding) > > Best, > Yuepeng Pan > > > > > > > > > > > > > > > 在 2024-12-24 10:37:57,"Ron Liu" 写道: > >+1(binding) > &

Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.

2024-12-19 Thread Feng Jin
public feature. I have already updated the relevant content. Best, Feng Jin On Thu, Dec 19, 2024 at 10:08 PM Lincoln Lee wrote: > Thanks Feng for driving this! > Supporting modification is an important improvement for Materialized Table. > > Regarding the alter table reserve his

Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.

2024-12-18 Thread Feng Jin
be manually set if state compatibility >is confirmed. > > > 4. Are you able to articulate the default behavior? > 5. How users can determine if states are compatible? > > Best, > Ron > > Feng Jin 于2024年12月16日周一 10:49写道: > >> Hi, everyone, >> >>

[DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.

2024-12-15 Thread Feng Jin
ts! Best, Feng Jin [1]. https://cwiki.apache.org/confluence/display/FLINK/FLIP-492%3A+Support+Query+Modifications+for+Materialized+Tables [2]. https://cwiki.apache.org/confluence/display/FLINK/FLIP-435%3A+Introduce+a+New+Materialized+Table+for+Simplifying+Data+Pipelines

Re: [VOTE]FLIP-480: Support to deploy script in application mode

2024-11-08 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Fri, Nov 8, 2024 at 5:37 PM yuanfeng hu wrote: > +1(no-binding) > > > Shengkai Fang 于2024年11月8日周五 15:11写道: > > > Hi everyone, > > > > I'd like to start a vote on FLIP-480: Support to deploy script in > > applicati

Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li

2024-11-05 Thread Feng Jin
Congratulations Junrui! Best, Feng On Wed, Nov 6, 2024 at 9:36 AM Rui Fan <1996fan...@gmail.com> wrote: > Congratulations Junrui! > > Best, > Rui > > On Wed, Nov 6, 2024 at 9:33 AM Guowei Ma wrote: > > > Congratulations Junrui! > > > > Best, > > Guowei > > > > > > On Wed, Nov 6, 2024 at 9:26 

Re: [DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set

2024-11-05 Thread Feng Jin
Hi, Xuyang, This issue is quite similar to FLINK-33936. Since the inconsistency in state expiration between the rank operator and downstream operators only occurs in specific scenarios, we might need to discuss whether it’s necessary to modify the default behavior. Best, Feng On Mon, Nov 4, 2

Re: [DISCUSS] FLIP-480: Support to deploy script in application mode

2024-10-29 Thread Feng Jin
Cluster may not be very > clear ? > > > > I have pushed a PoC branch about the change. Please take a look at > > https://github.com/fsk119/flink/tree/application-mode (I don't test it > > yet). At the mean time, I add a new method in the SqlGatewayService to > &g

Re: [DISCUSS] FLIP-480: Support to deploy script in application mode

2024-10-25 Thread Feng Jin
Hi, Shenkai Thank you for initiating this FLIP, I understand that supporting application mode for SQL gateway is very important. There are two small issues. > FLIP-480 is different from FLIP-316 1. Will FLIP-316 merge into Flink 2.0 too ? 2. Will SqlDriver use the same one? The detail

[jira] [Created] (FLINK-36242) Fix unstable test in MaterializedTableITCase

2024-09-09 Thread Feng Jin (Jira)
Feng Jin created FLINK-36242: Summary: Fix unstable test in MaterializedTableITCase Key: FLINK-36242 URL: https://issues.apache.org/jira/browse/FLINK-36242 Project: Flink Issue Type: Bug

Re: .ClassNotFoundException: org.apache.flink.table.data.util.DataFormatConverters$RowConverter

2024-09-06 Thread Feng Jin
sLoader.java:581) > at > > java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178) > at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:527) > ... 3 more > > On Thu, Sep 5, 2024 at 10:46 PM Feng Jin wrote: > > > Hi, Taher &g

Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs

2024-08-21 Thread Feng Jin
+1 (non-binding) Best, Feng On Thu, Aug 22, 2024 at 9:42 AM Ron Liu wrote: > +1(binding) > > Best, > Ron > > Zakelly Lan 于2024年8月21日周三 11:16写道: > > > +1 (binding) > > > > Best, > > Zakelly > > > > On Wed, Aug 21, 2024 at 10:33 AM Xuyang wrote: > > > > > Hi, everyone. > > > > > > I would like

Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su

2024-08-18 Thread Feng Jin
Congratulations, Xuannan! Best, Feng On Sun, Aug 18, 2024 at 3:08 PM Rui Fan <1996fan...@gmail.com> wrote: > Congratulations, Xuannan! > > Best, > Rui > > On Sun, Aug 18, 2024 at 2:20 PM Leonard Xu wrote: > > > Congratulations! Xuannan > > > > > > Best, > > Leonard > > > > >

Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs

2024-08-13 Thread Feng Jin
Hi, Xuyang Thank you for initiating this FLIP. I believe this is a significant feature for the future of Flink SQL, but I also share concerns about the maintenance costs related to the correctness, state compatibility, and performance of the two implementations. I fully support ensuring state comp

Re: [ANNOUNCE] Apache Flink 1.20.0 released

2024-08-02 Thread Feng Jin
Congratulations! Thanks to release managers and everyone involved! Best, Feng Jin On Fri, Aug 2, 2024 at 5:45 PM Yubin Li wrote: > Congrats! > Thanks to release managers and everyone involved for the excellent work ! > > Best, > Yubin Li > > On Fri, Aug 2, 2024 at 5:

Re: [VOTE] Release 1.20.0, release candidate #1

2024-07-21 Thread Feng Jin
Hi, weijie -1 (non-binding) During our testing process, we discovered a critical bug that impacts the correctness of the materialized table. A fix pr [1] is now prepared and will be merged within the next two days. I apologize for any inconvenience during the release process. [1]. https://issu

[jira] [Created] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode

2024-07-21 Thread Feng Jin (Jira)
Feng Jin created FLINK-35872: Summary: Fix the incorrect partition generation during period refresh in Full Mode Key: FLINK-35872 URL: https://issues.apache.org/jira/browse/FLINK-35872 Project: Flink

Re: [VOTE] FLIP-465: Introduce DESCRIBE FUNCTION

2024-07-04 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Thu, Jul 4, 2024 at 6:02 PM Martijn Visser wrote: > +1 (binding) > > On Thu, Jul 4, 2024 at 5:39 AM Yanquan Lv wrote: > > > Hi Natea, thanks for driving it. > > +1 (non-binding). > > > > Jim Hughes 于2024年7月4日周四 04:41写道: &

[jira] [Created] (FLINK-35734) Not override the user-defined checkpoint interval in continuous mode.

2024-06-30 Thread Feng Jin (Jira)
Feng Jin created FLINK-35734: Summary: Not override the user-defined checkpoint interval in continuous mode. Key: FLINK-35734 URL: https://issues.apache.org/jira/browse/FLINK-35734 Project: Flink

Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION

2024-06-30 Thread Feng Jin
Hi, Natea, Thank you for initiating this FLIP. Have you considered displaying parameter names? This would make it easier for users to use named parameters. Best, Feng On Sun, Jun 30, 2024 at 3:49 PM Yanquan Lv wrote: > Hi, Natea. This FLIP looks good from my side. > I also look forward to

Re: [VOTE] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join

2024-06-17 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Tue, Jun 18, 2024 at 10:24 AM Lincoln Lee wrote: > +1 (binding) > > > Best, > Lincoln Lee > > > Xintong Song 于2024年6月17日周一 13:39写道: > > > +1 (binding) > > > > Best, > > > > Xintong >

Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong

2024-06-17 Thread Feng Jin
Congratulations Zhongqiang !!! Best regards Feng Jin On Mon, Jun 17, 2024 at 7:01 PM Feifan Wang wrote: > Congratulations Zhongqiang ! > > > —— > > Best regards, > > Feifan Wang > > > > > At 2024-06-17 11:20:30, "Leonard Xu" wr

Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan

2024-06-17 Thread Feng Jin
Congratulations Hang!!!. Best Regards Feng Jin On Mon, Jun 17, 2024 at 7:08 PM Ahmed Hamdy wrote: > Congratulations Hang. > Regards Ahmed > > On Mon, 17 Jun 2024, 14:01 Feifan Wang, wrote: > > > Congratulations Hang ! > > > > > > —— &g

Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui

2024-06-05 Thread Feng Jin
Congratulations, Rui! Best, Feng Jin On Wed, Jun 5, 2024 at 8:23 PM Yanfei Lei wrote: > Congratulations, Rui! > > Best, > Yanfei > > Luke Chen 于2024年6月5日周三 20:08写道: > > > > Congrats, Rui! > > > > Luke > > > > On Wed, Jun 5, 2024 at 8:

Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo

2024-06-04 Thread Feng Jin
Congratulations, Weijie! Best, Feng Jin On Tue, Jun 4, 2024 at 9:03 PM Wencong Liu wrote: > Congratulations, Weijie! > > > > > Best, > > Wencong > > > > > At 2024-06-04 20:46:52, "Lijie Wang" wrote: > >Congratulations, Weijie! > &g

[jira] [Created] (FLINK-35479) Add end-to-end test for materialized table

2024-05-29 Thread Feng Jin (Jira)
Feng Jin created FLINK-35479: Summary: Add end-to-end test for materialized table Key: FLINK-35479 URL: https://issues.apache.org/jira/browse/FLINK-35479 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-26 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Mon, May 27, 2024 at 1:05 PM Benchao Li wrote: > +1 (binding) > > Yubin Li 于2024年5月25日周六 12:26写道: > > > > +1 (non-binding) > > > > Best, > > Yubin > > > > On Fri, May 24, 2024 at 2:04 PM Rui Fan &

Re: Re: [VOTE] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

2024-05-09 Thread Feng Jin
+1 (non-binding) Best, Feng On Thu, May 9, 2024 at 7:37 PM Xuyang wrote: > +1 (non-binding) > > > -- > > Best! > Xuyang > > > > > > At 2024-05-09 13:57:07, "Ron Liu" wrote: > >Sorry for the re-post, just to format this email content. > > > >Hi Dev > > > >Thank you to everyone for the

Re: [DISCUSS] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

2024-04-24 Thread Feng Jin
Hi Ron Thank you for initiating this FLIP. My current questions are as follows: 1. From my current understanding, the workflow handle should not be bound to the Dynamic Table. Therefore, if the workflow is modified, does it mean that the scheduling information corresponding to the Dynamic Table

[jira] [Created] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.

2024-04-24 Thread Feng Jin (Jira)
Feng Jin created FLINK-35230: Summary: Split FlinkSqlParserImplTest to reduce the code lines. Key: FLINK-35230 URL: https://issues.apache.org/jira/browse/FLINK-35230 Project: Flink Issue Type

Re: [VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-16 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Wed, Apr 17, 2024 at 2:28 PM Ron liu wrote: > +1(binding) > > Best, > Ron > > Ron liu 于2024年4月17日周三 14:27写道: > > > Hi Dev, > > > > Thank you to everyone for the feedback on FLIP-435: Introduce a New > > Materiali

Re: [ANNOUNCE] New Apache Flink Committer - Zakelly Lan

2024-04-16 Thread Feng Jin
Congratulations! Best, Feng On Tue, Apr 16, 2024 at 10:43 PM Ferenc Csaky wrote: > Congratulations! > > Best, > Ferenc > > > > > On Tuesday, April 16th, 2024 at 16:28, Jeyhun Karimov < > je.kari...@gmail.com> wrote: > > > > > > > Congratulations Zakelly! > > > > Regards, > > Jeyhun > > > > On T

Re: [ANNOUNCE] New Apache Flink PMC Member - Jing Ge

2024-04-12 Thread Feng Jin
Congratulations, Jing Best, Feng Jin On Fri, Apr 12, 2024 at 4:46 PM Samrat Deb wrote: > Congratulations, Jing! > > > On Fri, 12 Apr 2024 at 2:15 PM, Jiabao Sun wrote: > > > Congratulations, Jing! > > > > Best, > > Jiabao > &g

Re: [ANNOUNCE] New Apache Flink PMC Member - Lincoln Lee

2024-04-12 Thread Feng Jin
Congratulations, Lincoln! Best, Feng Jin On Fri, Apr 12, 2024 at 5:20 PM xiangyu feng wrote: > Congratulations, Lincoln! > > Best, > Xiangyu Feng > > Feifan Wang 于2024年4月12日周五 17:19写道: > > > Congratulations, Lincoln! > > > > > > ———

Re: [VOTE] FLIP-399: Flink Connector Doris

2024-04-09 Thread Feng Jin
+1 (non-binding) Best, Feng On Tue, Apr 9, 2024 at 5:56 PM gongzhongqiang wrote: > +1 (non-binding) > > Best, > > Zhongqiang Gong > > wudi <676366...@qq.com.invalid> 于2024年4月9日周二 10:48写道: > > > Hi devs, > > > > I would like to start a vote about FLIP-399 [1]. The FLIP is about > > contributing

Re: Re: [ANNOUNCE] Apache Paimon is graduated to Top Level Project

2024-03-31 Thread Feng Jin
Congratulations! Best, Feng Jin On Mon, Apr 1, 2024 at 10:51 AM weijie guo wrote: > Congratulations! > > Best regards, > > Weijie > > > Hang Ruan 于2024年4月1日周一 09:49写道: > > > Congratulations! > > > > Best, > > Hang > > > >

Re: [DISCUSS] FLIP-399: Flink Connector Doris

2024-03-25 Thread Feng Jin
most cases > unless you are restarting from a checkpoint that occurred a long time ago. > What do you think? > > > [1] > https://github.com/apache/doris/blob/master/fe/fe-common/src/main/java/org/apache/doris/common/Config.java#L163-L168 > > > Brs > di.wu > > &

Re: [DISCUSS] FLIP-399: Flink Connector Doris

2024-03-24 Thread Feng Jin
or/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java#L150-L160 > [2] > https://github.com/apache/doris-flink-connector/blob/master/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java#L89-L98 > > Brs > di.wu > > > > &g

Re: [DISCUSS] FLIP-399: Flink Connector Doris

2024-03-22 Thread Feng Jin
wo-phase commit, when a commit fails, the checkpoint will also > fail, and the job will be continuously retried. > > [1] > https://github.com/apache/doris-flink-connector/blob/master/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java#L58 > >

Re: [ANNOUNCE] Donation Flink CDC into Apache Flink has Completed

2024-03-20 Thread Feng Jin
Congratulations! Best, Feng On Thu, Mar 21, 2024 at 11:37 AM Ron liu wrote: > Congratulations! > > Best, > Ron > > Jark Wu 于2024年3月21日周四 10:46写道: > > > Congratulations and welcome! > > > > Best, > > Jark > > > > On Thu, 21 Mar 2024 at 10:35, Rui Fan <1996fan...@gmail.com> wrote: > > > > > Co

Re: [DISCUSS] FLIP-435: Introduce a New Dynamic Table for Simplifying Data Pipelines

2024-03-20 Thread Feng Jin
Hi Ron and Lincoln Thanks for driving this discussion. I believe it will greatly improve the convenience of managing user real-time pipelines. I have some questions. *Regarding Limitations of Dynamic Table:* > Does not support modifying the select statement after the dynamic table is created.

Re: [VOTE] FLIP-436: Introduce Catalog-related Syntax

2024-03-19 Thread Feng Jin
+1 (non-binding) Best, Feng On Tue, Mar 19, 2024 at 7:46 PM Ferenc Csaky wrote: > +1 (non-binding). > > Best, > Ferenc > > > > > On Tuesday, March 19th, 2024 at 12:39, Jark Wu wrote: > > > > > > > +1 (binding) > > > > Best, > > Jark > > > > On Tue, 19 Mar 2024 at 19:05, Yuepeng Pan panyuep...@

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Feng Jin
Congratulations! Best, Feng On Mon, Mar 18, 2024 at 6:18 PM Yuepeng Pan wrote: > Congratulations! > > > Thanks to release managers and everyone involved. > > > > > Best, > Yuepeng Pan > > > > > > > > > At 2024-03-18 18:09:45, "Yubin Li" wrote: > >Congratulations! > > > >Thanks to release manag

Re: [DISCUSS] FLIP-399: Flink Connector Doris

2024-03-14 Thread Feng Jin
Hi Di Thank you for initiating this FLIP, +1 for this. Regarding the option `doris.filter.query` of doris source table Can we directly implement the FilterPushDown capability of Flink Source like Jdbc Source [1] instead of introducing an option? Regarding two-phase commit, > At the same time,

Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

2024-03-13 Thread Feng Jin
r's > > business, there is no similar statement for users to use. > > > > According to the online discussion in FLINK-24939 [2] with Jark Wu and > Feng > > Jin, since `CatalogStore` > > has been introduced in FLIP-295 [3], we could use this component to >

Re: [VOTE] Release 1.19.0, release candidate #2

2024-03-11 Thread Feng Jin
+1 (non-binding) - Verified signatures and checksums - Verified that source does not contain binaries - Build source code successfully - Run a simple sql query successfully Best, Feng Jin On Tue, Mar 12, 2024 at 11:09 AM Ron liu wrote: > +1 (non binding) > > quickly verified: >

Re: [VOTE] FLIP-314: Support Customized Job Lineage Listener

2024-02-28 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Thu, Feb 29, 2024 at 4:41 AM Márton Balassi wrote: > +1 (binding) > > Marton > > On Wed, Feb 28, 2024 at 5:14 PM Gyula Fóra wrote: > > > +1 (binding) > > > > Gyula > > > > On Wed, Feb 28, 2024 at 11:10

Re: Temporal join on rolling aggregate

2024-02-23 Thread Feng Jin
+1 Support this feature. There are many limitations to using time window aggregation currently, and if we can declare watermark and time attribute on the view, it will make it easier for us to use time windows. Similarly, it would be very useful if the primary key could be declared in the view. Th

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Feng Jin
Congratulations, Jiabao! Best, Feng On Mon, Feb 19, 2024 at 7:35 PM Sergey Nuyanzin wrote: > Congratulations, Jiabao! > > On Mon, Feb 19, 2024 at 12:26 PM Yanquan Lv wrote: > > > Congratulations, Jiabao. > > > > He Wang 于2024年2月19日周一 19:21写道: > > > > > Congrats, Jiabao! > > > > > > On Mon, F

[jira] [Created] (FLINK-34312) Improve the handling of default node types when using named parameters.

2024-01-30 Thread Feng Jin (Jira)
Feng Jin created FLINK-34312: Summary: Improve the handling of default node types when using named parameters. Key: FLINK-34312 URL: https://issues.apache.org/jira/browse/FLINK-34312 Project: Flink

[jira] [Created] (FLINK-34265) Add the doc of named parameters

2024-01-29 Thread Feng Jin (Jira)
Feng Jin created FLINK-34265: Summary: Add the doc of named parameters Key: FLINK-34265 URL: https://issues.apache.org/jira/browse/FLINK-34265 Project: Flink Issue Type: Sub-task

Re: [SUMMARY] Flink 1.19 Release Sync 01/23/2024

2024-01-24 Thread Feng Jin
request that we merge the pull request next Monday(Jan 29th). I apologize if this affects your related schedule. [1]. https://issues.apache.org/jira/browse/FLINK-34054 Best regards, Feng Jin On Wed, Jan 24, 2024 at 10:00 PM Lincoln Lee wrote: > Hi devs, > > I'd like to share s

Re: Re: [VOTE] FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

2024-01-23 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Tue, Jan 23, 2024 at 5:46 PM Qingsheng Ren wrote: > +1 (binding) > > Thanks for driving this, Jiabao! > > Best, > Qingsheng > > On Fri, Jan 19, 2024 at 2:11 PM Jark Wu wrote: > > > +1 (binding) > > > > Best,

[jira] [Created] (FLINK-34058) Support optional parameters for named parameters

2024-01-10 Thread Feng Jin (Jira)
Feng Jin created FLINK-34058: Summary: Support optional parameters for named parameters Key: FLINK-34058 URL: https://issues.apache.org/jira/browse/FLINK-34058 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-34057) Support named parameters for functions

2024-01-10 Thread Feng Jin (Jira)
Feng Jin created FLINK-34057: Summary: Support named parameters for functions Key: FLINK-34057 URL: https://issues.apache.org/jira/browse/FLINK-34057 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34056) Support named parameters for procedures

2024-01-10 Thread Feng Jin (Jira)
Feng Jin created FLINK-34056: Summary: Support named parameters for procedures Key: FLINK-34056 URL: https://issues.apache.org/jira/browse/FLINK-34056 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34055) Introduce a new annotation for named parameters.

2024-01-10 Thread Feng Jin (Jira)
Feng Jin created FLINK-34055: Summary: Introduce a new annotation for named parameters. Key: FLINK-34055 URL: https://issues.apache.org/jira/browse/FLINK-34055 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-34054) FLIP-387: Support named parameters for functions and call procedures

2024-01-10 Thread Feng Jin (Jira)
Feng Jin created FLINK-34054: Summary: FLIP-387: Support named parameters for functions and call procedures Key: FLINK-34054 URL: https://issues.apache.org/jira/browse/FLINK-34054 Project: Flink

[RESULT][VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-09 Thread Feng Jin
hread/m3hw5cc1ovtvvplv9hpd56fzzl44xxcr Best, Feng Jin

Re: Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-09 Thread Feng Jin
Thank you all! Closing the vote. The result will be sent in a separate email. Best, Feng Jin On Wed, Jan 10, 2024 at 2:04 PM Hang Ruan wrote: > +1 (non-binding) > > Best, > Hang > > Jingsong Li 于2024年1月10日周三 12:03写道: > > > +1 > > > > On Wed,

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Tue, Jan 9, 2024 at 5:29 PM Yuxin Tan wrote: > +1 (non-binding) > > Best, > Yuxin > > > Márton Balassi 于2024年1月9日周二 17:25写道: > > > +1 (binding) > > > > On Tue, Jan 9, 2024 at 10:15 AM Leonard Xu wrote: > > &

Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-07 Thread Feng Jin
Hi Alexey Thank you for the reminder, the link has been updated. Best, Feng Jin On Sat, Jan 6, 2024 at 12:55 AM Alexey Leonov-Vendrovskiy < vendrov...@gmail.com> wrote: > Thanks for starting the vote! > Do you mind adding a link from the FLIP to this thread? > > Thanks, &

Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-05 Thread Feng Jin
menter. > > Regards, > Timo > > > On 05.01.24 05:06, Lincoln Lee wrote: > > +1 (binding) > > > > Best, > > Lincoln Lee > > > > > > Benchao Li 于2024年1月5日周五 11:46写道: > > > >> +1 (binding) > >> > >>

[VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-04 Thread Feng Jin
or an insufficient number of votes. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-387%3A+Support+named+parameters+for+functions+and+call+procedures [2] https://lists.apache.org/thread/bto7mpjvcx7d7k86owb00dwrm65jx8cn Best, Feng Jin

[jira] [Created] (FLINK-33996) Support disabling project rewrite when multiple exprs in the project reference the same project.

2024-01-04 Thread Feng Jin (Jira)
Feng Jin created FLINK-33996: Summary: Support disabling project rewrite when multiple exprs in the project reference the same project. Key: FLINK-33996 URL: https://issues.apache.org/jira/browse/FLINK-33996

Re: Re: [DISCUSS] FLIP-387: Support named parameters for functions and call procedures

2024-01-02 Thread Feng Jin
in the FLIP previously, I'll go over the code of PoC, and > post here if there are any more concerns. > > Xuyang 于2023年12月21日周四 10:39写道: > > > > > Hi, Benchao. > > > > > > When Feng Jin and I tried the poc together, we found that when using > udaf

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

2024-01-02 Thread Feng Jin
Congratulations, Alex! Best, Feng On Tue, Jan 2, 2024 at 11:04 PM Chen Yu wrote: > Congratulations, Alex! > > Best, > Yu Chen > > > 发件人: Zhanghao Chen > 发送时间: 2024年1月2日 22:44 > 收件人: dev > 抄送: Alexander Fedulov > 主题: Re: [ANNOUNCE] New Apache Flink Commi

[jira] [Created] (FLINK-33936) Mini-batch should output the result when the result is same as last if TTL is setted.

2023-12-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-33936: Summary: Mini-batch should output the result when the result is same as last if TTL is setted. Key: FLINK-33936 URL: https://issues.apache.org/jira/browse/FLINK-33936

Re: [DISCUSS] FLIP-387: Support named parameters for functions and call procedures

2023-12-14 Thread Feng Jin
it simple and don't allow overloading > named parameters. With the optionality, users can add an arbitrary > number of parameters to the signature of the same eval method. > > Regards, > Timo > > On 14.12.23 10:02, Feng Jin wrote: > > Hi all, > > > > > &g

[DISCUSS] FLIP-387: Support named parameters for functions and call procedures

2023-12-14 Thread Feng Jin
Hi all, Xuyang and I would like to start a discussion of FLIP-387: Support named parameters for functions and call procedures [1] Currently, when users call a function or call a procedure, they must specify all fields in order. When there are a large number of parameters, it is easy to make mist

Re: [PROPOSAL] Contribute Flink CDC Connectors project to Apache Flink

2023-12-06 Thread Feng Jin
This is incredibly exciting news, a big +1 for this. Thank you for the fantastic work on Flink CDC. We have created thousands of real-time integration jobs using Flink CDC connectors. Best, Feng On Thu, Dec 7, 2023 at 1:45 PM gongzhongqiang wrote: > It's very exciting to hear the news. > +1 f

Re: [DISCUSS] FLIP-392: Deprecate the Legacy Group Window Aggregation

2023-12-04 Thread Feng Jin
Hi xuyang, Thank you for initiating this proposal. I'm glad to see that TVF's functionality can be fully supported. Regarding the early fire, late fire, and allow lateness features, how will they be provided to users? The documentation doesn't seem to provide a detailed description of this part.

Re: Streaming data from AWS S3 Source

2023-11-23 Thread Feng Jin
Hi Neelabh You can use FileSystem Connector . for DataStream [1] for TableAPI [2] . And you need to put necessary dependency to your flink environment. [3] For Flink SQL setup, you can reference `sql getting started module`[4] [1]. https://nightlies.apache.org/flink/flink-docs-master/docs/c

Re: [VOTE] Release 1.16.3, release candidate #1

2023-11-23 Thread Feng Jin
+1(non-binding) - verified signatures and hashsums - Verified there are no binaries in the source archive - Built Flink from sources - Started local standalone cluster, submitted sql job using sql-client Best, Feng On Thu, Nov 23, 2023 at 11:00 PM Hang Ruan wrote: > +1 (non-binding) > > - veri

Re: [VOTE] Release 1.17.2, release candidate #1

2023-11-23 Thread Feng Jin
+1(non-binding) - verified signatures and hashsums - Verified there are no binaries in the source archive - Built Flink from sources - Started local standalone cluster, submitted sql job using sql-client Best, Feng On Thu, Nov 23, 2023 at 11:08 PM Hang Ruan wrote: > +1 (non-binding) > > - ver

Re: [VOTE] FLIP-390: Support System out and err to be redirected to LOG or discarded

2023-11-22 Thread Feng Jin
+1(non-binding) Best, Feng On Wed, Nov 22, 2023 at 6:37 PM Leonard Xu wrote: > +1(binding) > > Best, > Leonard > > > 2023年11月22日 下午6:19,Roman Khachatryan 写道: > > > > +1 (binding) > > > > > > Thanks for the proposal > > > > Regards, > > Roman > > > > On Wed, Nov 22, 2023, 10:08 AM Piotr Nowojsk

Re: [DISCUSS] FLIP-390: Support System out and err to be redirected to LOG or discarded

2023-11-14 Thread Feng Jin
; > file > > > > > > > name), > > > > > > > 3. Check the file size periodically: all logs are written by > log > > > > > plugin, > > > > > > > they can check the log file size after writing. However, > > > System.out >

Re: [DISCUSS] FLIP-390: Support System out and err to be redirected to LOG or discarded

2023-11-08 Thread Feng Jin
Hi, Rui. Thank you for initiating this proposal. I have a question regarding redirecting stdout and stderr to LOG: Will they be written to the taskManager.log file by default or the taskManager.out file? If we can make taskmanager.out splittable and rolling, would it be easier for users to use t

Re: [ANNOUNCE] Apache Flink 1.18.0 released

2023-10-26 Thread Feng Jin
Thanks for the great work! Congratulations Best, Feng Jin On Fri, Oct 27, 2023 at 12:36 AM Leonard Xu wrote: > Congratulations, Well done! > > Best, > Leonard > > On Fri, Oct 27, 2023 at 12:23 AM Lincoln Lee > wrote: > > > Thanks for the great work! Congrats

  1   2   >