Re: [DISCUSS]FLIP-163: SQL Client Improvements

2021-01-28 Thread Sebastian Liu
t syntax; > > > For more detailed changes, please refer to FLIP-163[1]. > > Look forward to your feedback. > > > Best, > Shengkai > > [1] > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-163%3A+SQL+Client+Improvements > -- *With kind regards ---

[jira] [Created] (FLINK-21125) Sum or Sum0 overflow quietly

2021-01-25 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-21125: - Summary: Sum or Sum0 overflow quietly Key: FLINK-21125 URL: https://issues.apache.org/jira/browse/FLINK-21125 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20898) Code of BatchExpand & LocalNoGroupingAggregateWithoutKeys grows beyond 64 KB

2021-01-08 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20898: - Summary: Code of BatchExpand & LocalNoGroupingAggregateWithoutKeys grows beyond 64 KB Key: FLINK-20898 URL: https://issues.apache.org/jira/browse/FLINK-2

Re: Support local aggregate push down for Blink batch planner

2021-01-08 Thread Sebastian Liu
Down for JDBC source > 4. ... > > Best, > Jark > > On Thu, 7 Jan 2021 at 23:27, Sebastian Liu wrote: > >> Hi Jark, >> >> Seems that we have reached the agreement on the proposal. Could you >> please help to assign the below jira ticket to me? >> ht

[jira] [Created] (FLINK-20896) [Local Agg Pushdown] Support SupportsAggregatePushDown for JDBC TableSource

2021-01-08 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20896: - Summary: [Local Agg Pushdown] Support SupportsAggregatePushDown for JDBC TableSource Key: FLINK-20896 URL: https://issues.apache.org/jira/browse/FLINK-20896

[jira] [Created] (FLINK-20895) [Local Agg Pushdown] Support LocalAggregatePushDown in Blink planner

2021-01-08 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20895: - Summary: [Local Agg Pushdown] Support LocalAggregatePushDown in Blink planner Key: FLINK-20895 URL: https://issues.apache.org/jira/browse/FLINK-20895 Project

[jira] [Created] (FLINK-20894) [Local Agg Pushdown] Introduce SupportsAggregatePushDown interface

2021-01-08 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20894: - Summary: [Local Agg Pushdown] Introduce SupportsAggregatePushDown interface Key: FLINK-20894 URL: https://issues.apache.org/jira/browse/FLINK-20894 Project: Flink

Re: Support local aggregate push down for Blink batch planner

2021-01-07 Thread Sebastian Liu
gt; Jark > > On Thu, 7 Jan 2021 at 10:16, Jingsong Li wrote: > >> Sounds good to me. >> >> We don't have to worry about future changes, because it has covered all >> the capabilities of calcite aggregation. >> >> Best, >> Jingsong >&g

Re: Support local aggregate push down for Blink batch planner

2021-01-06 Thread Sebastian Liu
> > boolean applyAggregates( > List groupingSets, > List aggregates, > DataType producedDataType); > } > > What do you think? > > Best, > Jark > > On Wed, 6 Jan 2021 at 19:56, Sebastian Liu wrote: > >> Hi Jingsong, Jark, >> >> Thx so much

Re: Support local aggregate push down for Blink batch planner

2021-01-06 Thread Sebastian Liu
;> Hi Sebastian, >>>>>> >>>>>> Well, I mean: >>>>>> >>>>>> `boolean applyAggregates(int[] groupingFields, List >>>>>> aggregateExpressions, DataType producedDataType);` >>>>>> VS >>>>>>

Re: Support local aggregate push down for Blink batch planner

2021-01-05 Thread Sebastian Liu
rrent design is very good, just put forward some ideas. > > Best, > Jingsong > > On Tue, Jan 5, 2021 at 1:55 PM Sebastian Liu > wrote: > > > Hi Jark, > > > > Thx for your further feedback and help. The interface of > > SupportsAggregatePushDown may i

Re: Support local aggregate push down for Blink batch planner

2021-01-04 Thread Sebastian Liu
; > > > On Tue, 5 Jan 2021 at 11:04, Kurt Young wrote: > >> Sorry for the typo -_-! >> I meant idea #2. >> >> Best, >> Kurt >> >> >> On Tue, Jan 5, 2021 at 10:59 AM Sebastian Liu >> wrote: >> >>> Hi Kurt, >>>

Re: Support local aggregate push down for Blink batch planner

2021-01-04 Thread Sebastian Liu
the typo -_-! > I meant idea #2. > > Best, > Kurt > > > On Tue, Jan 5, 2021 at 10:59 AM Sebastian Liu > wrote: > >> Hi Kurt, >> >> Thx a lot for your feedback. If local aggregation is more like a physical >> operator rather than logical >> oper

Re: Support local aggregate push down for Blink batch planner

2021-01-04 Thread Sebastian Liu
: > Local aggregation is more like a physical operator rather than logical > operator. I would suggest going with idea #1. > > Best, > Kurt > > > On Wed, Dec 30, 2020 at 8:31 PM Sebastian Liu > wrote: > > > Hi Jark, Thx a lot for your quick reply and valuable su

Re: Support local aggregate push down for Blink batch planner

2020-12-30 Thread Sebastian Liu
inition` and args. Because, it would be easier to know > what's the index and type of the arguments. > > 3) It would be better to list which connectors will be supported in the > plan? > > Best, > Jark > > > On Tue, 29 Dec 2020 at 00:49, Sebastian Liu wrote: >

[Discussion][FLINK-20416] Need a cached catalog for batch SQL job

2020-12-28 Thread Sebastian Liu
/FLINK-20416 IMO, this feature can further improve the stability and execution speed of analyze query for Flink SQL. Looking forward to your feedback, and any discussion or comments are welcome. -- *With kind regards Sebastian Liu 刘洋

Support local aggregate push down for Blink batch planner

2020-12-28 Thread Sebastian Liu
kind regards Sebastian Liu 刘洋 Institute of Computing Technology, Chinese Academy of Science Mobile\WeChat: +86—15201613655 E-mail: liuyang0...@gmail.com QQ: 3239559*

[jira] [Created] (FLINK-20791) Support local aggregate push down for Blink batch planner

2020-12-28 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20791: - Summary: Support local aggregate push down for Blink batch planner Key: FLINK-20791 URL: https://issues.apache.org/jira/browse/FLINK-20791 Project: Flink

[jira] [Created] (FLINK-20416) Need a cached catalog for batch SQL job

2020-11-30 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20416: - Summary: Need a cached catalog for batch SQL job Key: FLINK-20416 URL: https://issues.apache.org/jira/browse/FLINK-20416 Project: Flink Issue Type