Re: [ANNOUNCE] New Apache Flink PMC Member - Leonard Xu

2023-04-23 Thread Shuo Cheng
Congratulations, Leonard. Best, Shuo On Sun, Apr 23, 2023 at 7:43 PM Sergey Nuyanzin wrote: > Congratulations, Leonard! > > On Sun, Apr 23, 2023 at 1:38 PM Zhipeng Zhang > wrote: > > > Congratulations, Leonard. > > > > Hang Ruan 于2023年4月23日周日 19:03写道: > > > > > > Congratulations, Leonard. > >

Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

2023-04-23 Thread Shuo Cheng
Congratulations, Qingsheng! Best, Shuo On Sun, Apr 23, 2023 at 7:43 PM Sergey Nuyanzin wrote: > Congratulations, Qingsheng! > > On Sun, Apr 23, 2023 at 1:37 PM Zhipeng Zhang > wrote: > > > Congratulations, Qingsheng! > > > > Hang Ruan 于2023年4月23日周日 19:03写道: > > > > > > Congratulations, Qingsh

Re: [VOTE] FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration

2023-04-10 Thread Shuo Cheng
+ 1 (non-binding) Best Regards, Shuo On Mon, Apr 10, 2023 at 6:06 PM Jane Chan wrote: > Hi developers, > > Thanks for all the feedback on FLIP-292: Enhance COMPILED PLAN to support > operator-level state TTL configuration [1]. > Based on the discussion [2], we have come to a consensus, so I wou

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

2023-03-26 Thread Shuo Cheng
gt; SQL > > jobs, they need to edit the json file which is not supported by general > job > > submission systems such as flink sql-client, apache kyuubi, apache > > streampark and .etc. Users need to download the file and edit it > manually, > > but they may not have the permissions to

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

2023-03-23 Thread Shuo Cheng
Correction: “users can set 'scan.startup.mode' for kafka connector” -> “users can set 'scan.startup.mode' for kafka connector by dynamic table option” Shuo Cheng 于2023年3月23日 周四21:50写道: > Hi Jane, > Thanks for driving this, operator level state ttl is absolutely a des

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

2023-03-23 Thread Shuo Cheng
Hi Jane, Thanks for driving this, operator level state ttl is absolutely a desired feature. I would share my opinion as following: If the scope of this proposal is limited as an enhancement for compiled json plan, it makes sense. I think it does not conflict with configuring state ttl in other way

Re: [DISCUSS] FLIP-296: Watermark options for table API & SQL

2023-02-22 Thread Shuo Cheng
Hi Kui, Thanks for driving the discussion. It's quite useful to introduce Watermark options. I have some questions: What kind of hints is "WATERMARK_PARAMS"? Currently, we have two kinds of hints in Flink: Dynamic Table Options & Query Hints. As described in the Flip, "WATERMARK_PARAMS" is more l

Re: Proposal to improve the Apache Flink website

2023-02-20 Thread Shuo Cheng
Hey! +1 for the proposal, the first page of Flink is more like a tutorial document for developers compared to the other top apache projects. Looking forward to a more attractive Flink website. Best regards, Shuo On Tue, Feb 21, 2023 at 8:13 AM Mohan, Deepthi wrote: > Hi, > > I am a product man

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Shuo Cheng
Congratulations, Lincoln! On Tue, Jan 10, 2023 at 11:52 AM Jark Wu wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Lincoln Lee as a new Flink > committer. > > Lincoln Lee has been a long-term Flink contributor since 2017. He mainly > works on Flink > SQL parts and driv

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Shuo Cheng
Congratulations, Godfrey and Xingbo! Best, Shuo On Wed, Nov 23, 2022 at 12:19 PM Dian Fu wrote: > Hi everyone, > > On behalf of the Apache Flink PMC, I'm very happy to announce that Godfrey > He and Xingbo Huang have joined the Flink PMC! > > Godfrey He becomes a Flink committer in Sep 2020. Hi

[jira] [Created] (FLINK-29990) Unparsed SQL for SqlTableLike cannot be parsed correctly

2022-11-10 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-29990: -- Summary: Unparsed SQL for SqlTableLike cannot be parsed correctly Key: FLINK-29990 URL: https://issues.apache.org/jira/browse/FLINK-29990 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink Committer - Caizhi Weng

2022-09-14 Thread Shuo Cheng
Congratulations Caizhi, well deserved! Best, Shuo On Fri, Sep 9, 2022 at 9:41 AM Jingsong Lee wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Caizhi Weng as a new > Flink committer. > > Caizhi has been contributing to the Flink project for more than 3 > years, and has

Re: [ANNOUNCE] Table Store release-0.2 branch cut

2022-07-20 Thread Shuo Cheng
Awesome! Looking forward to the release. Best, Shuo On Wed, Jul 20, 2022 at 3:12 PM Leonard Xu wrote: > Thanks Jinsong for the great work, look forward to the release. > > Best, > Leonard > > > 2022年7月20日 下午2:50,Jingsong Li 写道: > > > > Hi Flink devs! > > > > The version on the main branch has

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

2022-06-13 Thread Shuo Cheng
Congratulations, Jingsong! On 6/13/22, Paul Lam wrote: > Congrats, Jingsong! Well deserved! > > Best, > Paul Lam > >> 2022年6月13日 16:31,Lincoln Lee 写道: >> >> Congratulations, Jingsong! >> >> Best, >> Lincoln Lee >> >> >> Jark Wu 于2022年6月13日周一 16:29写道: >> >>> Congrats, Jingsong! >>> >>> Cheers, >

Re: [ANNOUNCE] New PMC member: Yuan Mei

2022-03-14 Thread Shuo Cheng
Congratulations, Yuan! On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov wrote: > Congratulations, Yuan! > > -- > > Best regards, > Anton Kalashnikov > > 14.03.2022 09:13, Leonard Xu пишет: > > Congratulations Yuan! > > > > Best, > > Leonard > > > >> 2022年3月14日 下午4:09,Yangze Guo 写道: > >> > >> C

Re: Why does Flink Table API not wait for job to complete?

2022-03-08 Thread Shuo Cheng
I think what you need is something like: table.executeInsert("MySink").*await()* On Tue, Mar 8, 2022 at 8:24 PM Adesh Dsilva wrote: > Hi, > > I wrote a simple program using Flink Table API. > There is a Table source reading from an avro file, after doing some > operations the result is stored

Re: [DISCUSS] Enable scala formatting check

2022-03-02 Thread Shuo Cheng
+1, a lot of convenience will be brought then. 👍 On Wed, Mar 2, 2022 at 7:29 PM Leonard Xu wrote: > +1 from my side, thanks for driving this improvement. > > Best, > Leonard > > > 2022年3月2日 下午7:13,Jiangang Liu 写道: > > > > +1 for the feature. Good style management can help the developer a lot. >

Re: Change of focus

2022-03-02 Thread Shuo Cheng
Thanks for your efforts, Till. Good Luck! On Thu, Mar 3, 2022 at 12:00 AM Peter Huang wrote: > Hi Till, > > Thank you Till for monitoring and reviewing yarn related PRs. Good luck in > your next chapter! > > Best Regards > Peter Huang > > On Wed, Mar 2, 2022 at 3:34 AM Yu Li wrote: > > > Thanks

Re: [ANNOUNCE] New Apache Flink Committer - Jing Zhang

2021-11-15 Thread Shuo Cheng
Congratulations Jing! On Mon, Nov 15, 2021 at 10:23 PM Marios Trivyzas wrote: > Congrats Jing! > > On Mon, Nov 15, 2021 at 3:20 PM Till Rohrmann > wrote: > > > Congratulations Jing :-) > > > > Cheers, > > Till > > > > On Mon, Nov 15, 2021 at 2:48 PM Martijn Visser > > wrote: > > > > > Congratu

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

2021-11-11 Thread Shuo Cheng
Congrats, Leonard! On Fri, Nov 12, 2021 at 2:35 PM godfrey he wrote: > Congrats & well deserved, Leonard! > > Best, > Godfrey > > Yuepeng Pan 于2021年11月12日周五 下午2:28写道: > > > > Congrats. > > > > Best, > > Yuepeng Pan. > > At 2021-11-12 12:12:21, "Jark Wu" wrote: > > >Hi everyone, > > > > > >On b

[jira] [Created] (FLINK-24762) Remove agg function: INCR_SUM

2021-11-04 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-24762: -- Summary: Remove agg function: INCR_SUM Key: FLINK-24762 URL: https://issues.apache.org/jira/browse/FLINK-24762 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24598) Current IT case do not cover fallback path for hash aggregate

2021-10-20 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-24598: -- Summary: Current IT case do not cover fallback path for hash aggregate Key: FLINK-24598 URL: https://issues.apache.org/jira/browse/FLINK-24598 Project: Flink

[jira] [Created] (FLINK-24048) Move changeLog inference out of optimizing phase

2021-08-29 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-24048: -- Summary: Move changeLog inference out of optimizing phase Key: FLINK-24048 URL: https://issues.apache.org/jira/browse/FLINK-24048 Project: Flink Issue Type

[jira] [Created] (FLINK-23962) UpdateKind trait is not propagated properly in changeLog inference for DAG optimizing

2021-08-25 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-23962: -- Summary: UpdateKind trait is not propagated properly in changeLog inference for DAG optimizing Key: FLINK-23962 URL: https://issues.apache.org/jira/browse/FLINK-23962

[jira] [Created] (FLINK-23827) Fix ModifiedMonotonicity inference for some node

2021-08-16 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-23827: -- Summary: Fix ModifiedMonotonicity inference for some node Key: FLINK-23827 URL: https://issues.apache.org/jira/browse/FLINK-23827 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23310) Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream

2021-07-08 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-23310: -- Summary: Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream Key: FLINK-23310 URL: https://issues.apache.org/jira/browse/FLINK-23310

[jira] [Created] (FLINK-23136) Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public

2021-06-24 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-23136: -- Summary: Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public Key: FLINK-23136 URL: https://issues.apache.org/jira/browse/FLINK-23136

[jira] [Created] (FLINK-23086) Add getRuntimeExecutionMode to StreamExecutionEnvironment

2021-06-22 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-23086: -- Summary: Add getRuntimeExecutionMode to StreamExecutionEnvironment Key: FLINK-23086 URL: https://issues.apache.org/jira/browse/FLINK-23086 Project: Flink Issue

[jira] [Created] (FLINK-22586) Improve precision derivation for decimal arithmetics

2021-05-06 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-22586: -- Summary: Improve precision derivation for decimal arithmetics Key: FLINK-22586 URL: https://issues.apache.org/jira/browse/FLINK-22586 Project: Flink Issue Type

[jira] [Created] (FLINK-22304) Refactor some interfaces for TVF based window to improve the scalability

2021-04-16 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-22304: -- Summary: Refactor some interfaces for TVF based window to improve the scalability Key: FLINK-22304 URL: https://issues.apache.org/jira/browse/FLINK-22304 Project: Flink

[jira] [Created] (FLINK-22148) Planner rules should use RexCall#equsls to check whether two rexCalls are equivalent

2021-04-07 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-22148: -- Summary: Planner rules should use RexCall#equsls to check whether two rexCalls are equivalent Key: FLINK-22148 URL: https://issues.apache.org/jira/browse/FLINK-22148

[jira] [Created] (FLINK-22063) Lookup Join outputs wrong results for some scenario

2021-03-31 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-22063: -- Summary: Lookup Join outputs wrong results for some scenario Key: FLINK-22063 URL: https://issues.apache.org/jira/browse/FLINK-22063 Project: Flink Issue Type

[jira] [Created] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

2021-03-04 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-21613: -- Summary: Parse Compute Column with `IN` expression throws NPE Key: FLINK-21613 URL: https://issues.apache.org/jira/browse/FLINK-21613 Project: Flink Issue Type

[jira] [Created] (FLINK-20826) Fix bug in streaming SQL examples

2020-12-31 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-20826: -- Summary: Fix bug in streaming SQL examples Key: FLINK-20826 URL: https://issues.apache.org/jira/browse/FLINK-20826 Project: Flink Issue Type: New Feature

[DISCUSS] Make Temporal Join syntax easier to use

2020-12-20 Thread Shuo Cheng
Hi community, Temporal table join in Flink is a powerful feature, especially processing time temporal table join, which is very commonly used in production. However, the syntax of temporal table join only supports 'FOR SYSTEM_TIME AS OF' left table's time attribute field currently. e.g., ``` SELE

[jira] [Created] (FLINK-20670) Support query hints for Flink SQL

2020-12-17 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-20670: -- Summary: Support query hints for Flink SQL Key: FLINK-20670 URL: https://issues.apache.org/jira/browse/FLINK-20670 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17651) DecomposeGroupingSetsRule generates wrong plan when there exist distinct agg and simple agg with same filter

2020-05-13 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-17651: -- Summary: DecomposeGroupingSetsRule generates wrong plan when there exist distinct agg and simple agg with same filter Key: FLINK-17651 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-17649) Generated hash aggregate code may produce NPE when there exists an aggregate call with Filter.

2020-05-13 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-17649: -- Summary: Generated hash aggregate code may produce NPE when there exists an aggregate call with Filter. Key: FLINK-17649 URL: https://issues.apache.org/jira/browse/FLINK-17649

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

2020-04-17 Thread Shuo Cheng
Congratulations, Hequn Best, Shuo On 4/17/20, hufeih...@mails.ucas.ac.cn wrote: > Congratulations , Hequn > > Best wish > > > hufeih...@mails.ucas.ac.cn > Congratulations, Hequn! > > Paul Lam 于2020年4月17日周五 下午3:02写道: > >> Congrats Hequn! Thanks a lot for your contribution to the community! >> >>

[jira] [Created] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-16578: -- Summary: join lateral table function with condition fails with exception Key: FLINK-16578 URL: https://issues.apache.org/jira/browse/FLINK-16578 Project: Flink

[jira] [Created] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

2020-03-12 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-16577: -- Summary: Exception will be thrown when computing columnInterval relmetadata in some case Key: FLINK-16577 URL: https://issues.apache.org/jira/browse/FLINK-16577 Project

[ANNOUNCE] Dian Fu becomes a Flink committer

2020-01-16 Thread Shuo Cheng
Congratulations! Dian Fu > Xingbo Wei Zhong 于2020年1月16日周四 下午6:13写道: >> jincheng sun > 于2020年1月16日周四 下午5:58写道:

[jira] [Created] (FLINK-15537) Type of keys should be `BinaryRow` when manipulating map state with `BaseRow` as key type.

2020-01-09 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-15537: -- Summary: Type of keys should be `BinaryRow` when manipulating map state with `BaseRow` as key type. Key: FLINK-15537 URL: https://issues.apache.org/jira/browse/FLINK-15537

[jira] [Created] (FLINK-15466) `FlinkAggregateExpandDistinctAggregatesRule` generates wrong plan for cases that have distinct aggs with filter.

2020-01-02 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-15466: -- Summary: `FlinkAggregateExpandDistinctAggregatesRule` generates wrong plan for cases that have distinct aggs with filter. Key: FLINK-15466 URL: https://issues.apache.org/jira/browse