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-27 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

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-17 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

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
a/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 > > > > > 2024年3月22日 1

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

2024-03-22 Thread Feng Jin
ase 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: > > > > >

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

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

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

2024-03-15 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

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

2024-03-13 Thread Feng Jin
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 > > imple

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.

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,

[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 some h

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
/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
. > > 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) > >> > >> Feng Jin 于2024

[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
e 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, Calcite

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

[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
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, > > > > > > Xuyang and I would lik

[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

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

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

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].

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) > > -

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) > > -

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

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

2023-11-14 Thread Feng Jin
e size periodically: all logs are written by > log > > > > > plugin, > > > > > > > they can check the log file size after writing. However, > > > System.out > > > > > > > are written directly. And flink must start a thread to check > > th

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

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

Re: [VOTE] FLIP-373: Support Configuring Different State TTLs using SQL Hint

2023-10-22 Thread Feng Jin
+1(non-binding) Best, Feng On Mon, Oct 23, 2023 at 11:58 AM Xuyang wrote: > +1(non-binding) > > > > > -- > > Best! > Xuyang > > > > > > At 2023-10-23 11:38:15, "Jane Chan" wrote: > >Hi developers, > > > >Thanks for all the feedback on FLIP-373: Support Configuring Different > >State

Re: [ANNOUNCE] New Apache Flink Committer - Ron Liu

2023-10-15 Thread Feng Jin
Congratulations, Ron! Best, Feng On Mon, Oct 16, 2023 at 11:22 AM yh z wrote: > Congratulations, Ron! > > Best, > Yunhong (SwuferHong) > > Yuxin Tan 于2023年10月16日周一 11:12写道: > > > Congratulations, Ron! > > > > Best, > > Yuxin > > > > > > Junrui Lee 于2023年10月16日周一 10:24写道: > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Jane Chan

2023-10-15 Thread Feng Jin
Congratulations Jane! Best, Feng On Mon, Oct 16, 2023 at 11:23 AM yh z wrote: > Congratulations Jane! > > Best, > Yunhong (swuferHong) > > Yuxin Tan 于2023年10月16日周一 11:11写道: > > > Congratulations Jane! > > > > Best, > > Yuxin > > > > > > xiangyu feng 于2023年10月16日周一 10:27写道: > > > > >

Re: Re: [DISCUSS] FLIP-373: Support Configuring Different State TTLs using SQL Hint

2023-10-10 Thread Feng Jin
;resulting in the loss of the hint at this step. To support this, we may > >need to rewrite some optimization rules in Calcite, which could be a > >follow-up work if required. > > > >Best, > >Jane > > > >On Tue, Oct 10, 2023 at 1:40 AM Feng Jin wrote: > > &g

Re: [DISCUSS] FLIP-373: Support Configuring Different State TTLs using SQL Hint

2023-10-09 Thread Feng Jin
Hi Jane, Thank you for proposing this FLIP. I believe that this FLIP will greatly enhance the flexibility of setting state, and by setting different operators' TTL, it can also increase job stability, especially in regular join scenarios. The parameter design is very concise, big +1 for this,

Re: [VOTE] FLIP-367: Support Setting Parallelism for Table/SQL Sources

2023-10-09 Thread Feng Jin
+1 (non-binding) Best, Feng On Mon, Oct 9, 2023 at 3:12 PM Yangze Guo wrote: > +1 (binding) > > Best, > Yangze Guo > > On Mon, Oct 9, 2023 at 2:46 PM Yun Tang wrote: > > > > +1 (binding) > > > > Best > > Yun Tang > > > > From: Weihua Hu > > Sent: Monday,

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

2023-09-25 Thread Feng Jin
+1(no-binding) thanks for driving this proposal Best, Feng On Mon, Sep 25, 2023 at 11:19 PM Jing Ge wrote: > +1(binding) Thanks! > > Best Regards, > Jing > > On Sun, Sep 24, 2023 at 10:30 PM Shammon FY wrote: > > > Hi devs, > > > > Thanks for all the feedback on FLIP-314: Support

Re: [DISCUSS] Implementing SQL remote functions

2023-09-20 Thread Feng Jin
Hi Alan I believe that supporting asynchronous UDF is a valuable feature. Currently, there is a similar FLIP[1] available: Can this meet your needs? [1]. https://cwiki.apache.org/confluence/display/FLINK/FLIP-313%3A+Add+support+of+User+Defined+AsyncTableFunction Best, Feng On Thu, Sep 21,

Re: [DISCUSS] FLIP-367: Support Setting Parallelism for Table/SQL Sources

2023-09-16 Thread Feng Jin
Hi, Zhanghao Thank you for proposing this FLIP, it is a very meaningful feature. I agree that currently we may only consider the parallelism setting of the source itself. If we consider the parallelism setting of other operators, it may make the entire design more complex. Regarding the

Re: [VOTE] FLIP-334: Decoupling autoscaler and kubernetes and support the Standalone Autoscaler

2023-09-13 Thread Feng Jin
Thanks for driving this, looking forward to this feature. +1 (non-binding) Best, Feng On Wed, Sep 13, 2023 at 9:11 PM Chen Zhanghao wrote: > Thanks for driving this. +1 (non-binding) > > Best, > Zhanghao Chen > > 发件人: Rui Fan <1996fan...@gmail.com> > 发送时间:

[jira] [Created] (FLINK-33070) Add doc for 'unnest'

2023-09-11 Thread Feng Jin (Jira)
Feng Jin created FLINK-33070: Summary: Add doc for 'unnest' Key: FLINK-33070 URL: https://issues.apache.org/jira/browse/FLINK-33070 Project: Flink Issue Type: Improvement Components

Re: [DISCUSS][FLINK-31788][FLINK-33015] Add back Support emitUpdateWithRetract for TableAggregateFunction

2023-09-10 Thread Feng Jin
Thanks Jane for following up on this issue! +1 for adding it back first. Supporting emitUpdateWithRetract for TableAggregateFunction is a good feature, we should support it unless there are better alternatives. Best, Feng On Thu, Sep 7, 2023 at 11:01 PM Lincoln Lee wrote: > Thanks to Jane

[jira] [Created] (FLINK-32976) NullpointException when starting flink cluster

2023-08-28 Thread Feng Jin (Jira)
Feng Jin created FLINK-32976: Summary: NullpointException when starting flink cluster Key: FLINK-32976 URL: https://issues.apache.org/jira/browse/FLINK-32976 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Apache Flink PMC Member - Matthias Pohl

2023-08-04 Thread Feng Jin
Congratulations, Matthias! Best regards Feng On Fri, Aug 4, 2023 at 4:29 PM weijie guo wrote: > Congratulations, Matthias! > > Best regards, > > Weijie > > > Wencong Liu 于2023年8月4日周五 15:50写道: > > > Congratulations, Matthias! > > > > Best, > > Wencong Liu > > > > > > > > > > > > > > > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Weihua Hu

2023-08-04 Thread Feng Jin
Congratulations Weihua! Best regards, Feng On Fri, Aug 4, 2023 at 4:28 PM weijie guo wrote: > Congratulations Weihua! > > Best regards, > > Weijie > > > Lijie Wang 于2023年8月4日周五 15:28写道: > > > Congratulations, Weihua! > > > > Best, > > Lijie > > > > yuxia 于2023年8月4日周五 15:14写道: > > > > >

Re: Support read ROWKIND metadata by ROW_KIND() function

2023-07-24 Thread Feng Jin
Hi casel, Thank you for initiating the discussion about RowKind meta. I believe that in certain scenarios, it is necessary to expose RowKind. We also have similar situations internally: In simple terms, we need to be able to control the behavior of RowKind in both Source and Sink: - When reading

Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-24 Thread Feng Jin
Congratulations, Yong Fang Best, Feng On Mon, Jul 24, 2023 at 3:12 PM Leonard Xu wrote: > Congratulations, Yong Fang > > Best, > Leonard > > > On Jul 24, 2023, at 2:01 PM, yuxia wrote: > > > > Congrats, Shammon! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Benchao Li"

[jira] [Created] (FLINK-32653) Add doc for catalog store

2023-07-23 Thread Feng Jin (Jira)
Feng Jin created FLINK-32653: Summary: Add doc for catalog store Key: FLINK-32653 URL: https://issues.apache.org/jira/browse/FLINK-32653 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-32647) Support config catalog store in python table environment

2023-07-22 Thread Feng Jin (Jira)
Feng Jin created FLINK-32647: Summary: Support config catalog store in python table environment Key: FLINK-32647 URL: https://issues.apache.org/jira/browse/FLINK-32647 Project: Flink Issue Type

[jira] [Created] (FLINK-32569) Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread Feng Jin (Jira)
Feng Jin created FLINK-32569: Summary: Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface Key: FLINK-32569 URL: https://issues.apache.org/jira/browse/FLINK

Re: Re: [ANNOUNCE] Apache Flink has won the 2023 SIGMOD Systems Award

2023-07-04 Thread Feng Jin
Congratulations! Best, Feng Jin On Tue, Jul 4, 2023 at 4:13 PM Yuxin Tan wrote: > Congratulations! > > Best, > Yuxin > > > Dunn Bangui 于2023年7月4日周二 16:04写道: > > > Congratulations! > > > > Best, > > Bangui Dunn > > > > Y

[jira] [Created] (FLINK-32475) Add doc for time travel

2023-06-28 Thread Feng Jin (Jira)
Feng Jin created FLINK-32475: Summary: Add doc for time travel Key: FLINK-32475 URL: https://issues.apache.org/jira/browse/FLINK-32475 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-32474) Support time travel in table planner

2023-06-28 Thread Feng Jin (Jira)
Feng Jin created FLINK-32474: Summary: Support time travel in table planner Key: FLINK-32474 URL: https://issues.apache.org/jira/browse/FLINK-32474 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32473) Introduce base interfaces for time travel

2023-06-28 Thread Feng Jin (Jira)
Feng Jin created FLINK-32473: Summary: Introduce base interfaces for time travel Key: FLINK-32473 URL: https://issues.apache.org/jira/browse/FLINK-32473 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32472) FLIP-308: Support Time Travel

2023-06-28 Thread Feng Jin (Jira)
Feng Jin created FLINK-32472: Summary: FLIP-308: Support Time Travel Key: FLINK-32472 URL: https://issues.apache.org/jira/browse/FLINK-32472 Project: Flink Issue Type: New Feature

Re: [VOTE] FLIP-303: Support REPLACE TABLE AS SELECT statement

2023-06-28 Thread Feng Jin
+1 (no-binding) Best Feng On Wed, Jun 28, 2023 at 11:03 PM Jing Ge wrote: > +1(binding) > > On Wed, Jun 28, 2023 at 1:51 PM Mang Zhang wrote: > > > +1 (no-binding) > > > > > > -- > > > > Best regards, > > Mang Zhang > > > > > > > > > > > > At 2023-06-28 17:48:15, "yuxia" wrote: > > >Hi

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

2023-06-27 Thread Feng Jin
Hi Shammon Thank you for proposing this FLIP. I think the Flink Job lineage is a very useful feature. I have few question: 1. For DataStream Jobs, users need to set up lineage relationships when building DAGs for their custom sources and sinks. However, for some common connectors such as Kafka

[jira] [Created] (FLINK-32433) Add build-in FileCatalogStore

2023-06-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-32433: Summary: Add build-in FileCatalogStore Key: FLINK-32433 URL: https://issues.apache.org/jira/browse/FLINK-32433 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32432) Support CatalogStore in Flink SQL gateway

2023-06-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-32432: Summary: Support CatalogStore in Flink SQL gateway Key: FLINK-32432 URL: https://issues.apache.org/jira/browse/FLINK-32432 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32431) Support configuring CatalogStore in Table API

2023-06-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-32431: Summary: Support configuring CatalogStore in Table API Key: FLINK-32431 URL: https://issues.apache.org/jira/browse/FLINK-32431 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32430) Support configuring CatalogStore through flink conf

2023-06-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-32430: Summary: Support configuring CatalogStore through flink conf Key: FLINK-32430 URL: https://issues.apache.org/jira/browse/FLINK-32430 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-32429) Introduce CatalogStore in CatalogManager to support lazy initialization of catalogs and persistence of catalog configurations

2023-06-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-32429: Summary: Introduce CatalogStore in CatalogManager to support lazy initialization of catalogs and persistence of catalog configurations Key: FLINK-32429 URL: https://issues.apache.org

[jira] [Created] (FLINK-32428) Introduce base interfaces for CatalogStore

2023-06-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-32428: Summary: Introduce base interfaces for CatalogStore Key: FLINK-32428 URL: https://issues.apache.org/jira/browse/FLINK-32428 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32427) FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

2023-06-25 Thread Feng Jin (Jira)
Feng Jin created FLINK-32427: Summary: FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations Key: FLINK-32427 URL: https://issues.apache.org/jira/browse/FLINK-32427

[RESULT][VOTE]FLIP-308: Support Time Travel

2023-06-22 Thread Feng Jin
Hi everyone, Happy to announce that FLIP-308[1] has been approved! According to the vote thread[2], there are 7 approving votes, out of which 6 are binding: - yuxia (binding) - Lincoln Lee (binding) - Benchao Li (binding) - Jing Ge (binding) - Leonard Xu (binding) - John Roesler (non-binding) -

[VOTE] FLIP-308: Support Time Travel

2023-06-19 Thread Feng Jin
Hi everyone Thanks for all the feedback about the FLIP-308: Support Time Travel[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 22, 12:00AM GMT) unless there is an objection or an insufficient number of

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

2023-06-19 Thread Feng Jin
Hi everyone, Happy to announce that FLIP-295[1] has been approved! According to the vote thread[2], there are 7 approving votes, out of which 5 are binding: - Hang Ruan (non-binding) - Rui Fan (binding) - Jing Ge (binding) - Dong Lin (binding) - Leonard Xu (binding) - Shammon FY (non-binding) -

Re: [DISCUSS] FLIP-308: Support Time Travel In Batch Mode

2023-06-15 Thread Feng Jin
at 10:57 AM Feng Jin wrote: > Thanks Benchao and Leonard. > > 'Implicitly type conversion' makes sense to me. I will emphasize the > 'Implicitly type conversion' in the document. > > > Best, > Feng > > On Sat, Jun 10, 2023 at 10:11 AM Benchao Li wrote: >

Re: [VOTE] FLIP-294: Support Customized Catalog Modification Listener

2023-06-15 Thread Feng Jin
+1(no-binding) Best, Feng On Thu, Jun 15, 2023 at 8:33 PM liu ron wrote: > +1(no-binding) > > Best, > Ron > > yuxia 于2023年6月15日周四 20:15写道: > > > +1 (binding) > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Leonard Xu" > > 收件人: "dev" > > 发送时间: 星期四, 2023年 6 月 15日 下午

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

[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

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

2023-06-12 Thread Feng Jin
On Tue, Jun 13, 2023 at 10:42 AM Aitozi wrote: > 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写道:

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 295: Support persistence of Catalog configuration and asynchronous registration

2023-06-12 Thread Feng Jin
+of+catalog+configurations Best, Feng On Mon, Jun 12, 2023 at 10:54 AM Feng Jin wrote: > hi, Hang > > Thanks for your reply, Make sense to me, I updated the FLIP. > > > Best, > > Feng > > > > On Fri, Jun 9, 2023 at 3:34 PM Hang Ruan wrote: > >&g

  1   2   >