[jira] [Created] (FLINK-11455) Support evictor operations on slicing and merging operators

2019-01-29 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11455: - Summary: Support evictor operations on slicing and merging operators Key: FLINK-11455 URL: https://issues.apache.org/jira/browse/FLINK-11455 Project: Flink Issue

[jira] [Created] (FLINK-11454) Support MergedStream operation

2019-01-29 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11454: - Summary: Support MergedStream operation Key: FLINK-11454 URL: https://issues.apache.org/jira/browse/FLINK-11454 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-11453) Support SliceStream with forwardable pane info

2019-01-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11453: -- Summary: Support SliceStream with forwardable pane info (was: Support SliceWindow with forwardable

[jira] [Created] (FLINK-11453) Support SliceWindow with forwardable pane info

2019-01-29 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11453: - Summary: Support SliceWindow with forwardable pane info Key: FLINK-11453 URL: https://issues.apache.org/jira/browse/FLINK-11453 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

2019-01-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Affects Version/s: 1.7.0 > Slicing Window Optimization > --- > >

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

2019-01-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Component/s: DataStream API > Slicing Window Optimization > --- > >

[jira] [Created] (FLINK-11276) Slicing Window Optimization

2019-01-07 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11276: - Summary: Slicing Window Optimization Key: FLINK-11276 URL: https://issues.apache.org/jira/browse/FLINK-11276 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-11276) Slicing Window Optimization

2019-01-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11276: - Assignee: Rong Rong > Slicing Window Optimization > --- > >

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2019-01-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-11271 > Improve Kerberos

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication Keytab discovery on YARN

2019-01-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Summary: Improve Kerberos Authentication Keytab discovery on YARN (was: Improve Kerberos

[jira] [Created] (FLINK-11271) Improve Kerberos Credential Distribution

2019-01-04 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11271: - Summary: Improve Kerberos Credential Distribution Key: FLINK-11271 URL: https://issues.apache.org/jira/browse/FLINK-11271 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-14 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721857#comment-16721857 ] Rong Rong commented on FLINK-11088: --- I further dig into the details on the document on Hadoop side and

[jira] [Comment Edited] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-14 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721857#comment-16721857 ] Rong Rong edited comment on FLINK-11088 at 12/14/18 11:03 PM: -- I further

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-12 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Description: Currently flink-yarn assumes keytab is shipped as application master environment local

[jira] [Closed] (FLINK-9232) Add harness test for AggregationCodeGenerator

2018-12-12 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-9232. Resolution: Duplicate > Add harness test for AggregationCodeGenerator >

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-11 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Description: Currently flink-yarn assumes keytab is shipped as application master environment local

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

2018-12-10 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716173#comment-16716173 ] Rong Rong commented on FLINK-11081: --- +1 to this feature. Very helpful actually for lots of our use

[jira] [Commented] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-09 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16714128#comment-16714128 ] Rong Rong commented on FLINK-11088: --- Initial investigation needs to find a way to distinguish between

[jira] [Assigned] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11088: - Assignee: Rong Rong > Improve Kerberos Authentication using Keytab in YARN proxy user mode >

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Component/s: Security > Improve Kerberos Authentication using Keytab in YARN proxy user mode >

[jira] [Created] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-06 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11088: - Summary: Improve Kerberos Authentication using Keytab in YARN proxy user mode Key: FLINK-11088 URL: https://issues.apache.org/jira/browse/FLINK-11088 Project: Flink

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706398#comment-16706398 ] Rong Rong commented on FLINK-11010: --- Based on the discussion in the mailing list:

[jira] [Commented] (FLINK-8739) Optimize runtime support for distinct filter

2018-11-30 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704949#comment-16704949 ] Rong Rong commented on FLINK-8739: -- No I haven't started. please feel free to assign to yourself. >

[jira] [Created] (FLINK-11006) Update Calcite dependency to 1.18

2018-11-26 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11006: - Summary: Update Calcite dependency to 1.18 Key: FLINK-11006 URL: https://issues.apache.org/jira/browse/FLINK-11006 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

2018-11-10 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682733#comment-16682733 ] Rong Rong commented on FLINK-7001: -- Thanks for the inspiration from [~pgrulich] and [~aljoscha]. I have

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-05 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676222#comment-16676222 ] Rong Rong commented on FLINK-9172: -- Thanks for the info [~xuefuz]. I wasn't aware that this ticket was

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-03 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674101#comment-16674101 ] Rong Rong commented on FLINK-9172: -- Hi [~xuefuz] I think the scope of this JIRA goes beyond supporting

[jira] [Commented] (FLINK-7342) Add support for Regular Expression Operators (RLIKE)

2018-10-30 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669563#comment-16669563 ] Rong Rong commented on FLINK-7342: -- Seems like {{SIMILAR TO}} was already supported in Flink, should we

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-15 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-10556: -- Description: This is an umbrella JIRA tracking all enhancement and issues related to integrating

[jira] [Assigned] (FLINK-8880) Validate configurations for SQL Client

2018-10-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-8880: Assignee: (was: Rong Rong) > Validate configurations for SQL Client >

[jira] [Commented] (FLINK-8880) Validate configurations for SQL Client

2018-10-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638159#comment-16638159 ] Rong Rong commented on FLINK-8880: -- [~twalthr] yes aboslutely. please go ahead. > Validate

[jira] [Commented] (FLINK-10474) Don't translate IN to JOIN with VALUES for streaming queries

2018-10-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635666#comment-16635666 ] Rong Rong commented on FLINK-10474: --- Yes. I think having cascaded predicates are definitely not the

[jira] [Commented] (FLINK-10474) Don't translate IN to JOIN with VALUES for streaming queries

2018-10-01 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634867#comment-16634867 ] Rong Rong commented on FLINK-10474: --- Voting for the first approach. I was actually wondering. Is

[jira] [Commented] (FLINK-10273) Access composite type fields after a function

2018-09-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607907#comment-16607907 ] Rong Rong commented on FLINK-10273: --- I found a solution via modifying Calcite {{Parser.jj}}. However,

[jira] [Assigned] (FLINK-10273) Access composite type fields after a function

2018-09-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-10273: - Assignee: Rong Rong > Access composite type fields after a function >

[jira] [Commented] (FLINK-10273) Access composite type fields after a function

2018-09-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606511#comment-16606511 ] Rong Rong commented on FLINK-10273: --- Yup. I can take a deeper look at this problem actually. This has

[jira] [Commented] (FLINK-10273) Access composite type fields after a function

2018-09-05 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605112#comment-16605112 ] Rong Rong commented on FLINK-10273: --- I was able to reproduce it on SQL but not Table API. See:

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-09-05 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604542#comment-16604542 ] Rong Rong commented on FLINK-9172: -- [~eronwright] oh absolutely! Please feel free to assigned it to

[jira] [Comment Edited] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-09-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16601690#comment-16601690 ] Rong Rong edited comment on FLINK-9172 at 9/2/18 10:41 PM: --- Hi folks. Sorry for

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-09-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16601690#comment-16601690 ] Rong Rong commented on FLINK-9172: -- Hi folks. Sorry for not taking this task for so long. I think

[jira] [Comment Edited] (FLINK-10273) Access composite type fields after a function

2018-08-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598959#comment-16598959 ] Rong Rong edited comment on FLINK-10273 at 8/31/18 4:13 PM: sounds good.

[jira] [Commented] (FLINK-10273) Access composite type fields after a function

2018-08-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598959#comment-16598959 ] Rong Rong commented on FLINK-10273: --- sounds good. FLINK-10019 is pretty specific. but the underlying

[jira] [Updated] (FLINK-9501) Allow Object or Wildcard type in user-define functions as parameter types but not result types

2018-08-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9501: - Description: Idea here is to treat every Java parameter objects type as SQL ANY type. While

[jira] [Commented] (FLINK-9501) Allow Object or Wildcard type in user-define functions as parameter types but not result types

2018-08-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598895#comment-16598895 ] Rong Rong commented on FLINK-9501: -- https://github.com/apache/flink/pull/6472 introduced some of the

[jira] [Updated] (FLINK-9501) Allow Object or Wildcard type in user-define functions as parameter types but not result types

2018-08-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9501: - Description: Idea here is to treat every Java parameter objects type as SQL ANY type. While

[jira] [Commented] (FLINK-10273) Access composite type fields after a function

2018-08-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598786#comment-16598786 ] Rong Rong commented on FLINK-10273: --- [~twalthr] Yes I remember there are cases where resulting

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-08-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596917#comment-16596917 ] Rong Rong commented on FLINK-9172: -- [~eronwright] as far as I know, similar to table source and sink.

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-08-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596068#comment-16596068 ] Rong Rong commented on FLINK-9172: -- Yes. I think so too. the only thing missing was

[jira] [Commented] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-08-27 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16593861#comment-16593861 ] Rong Rong commented on FLINK-10222: --- I think making it exactly match is probably the best solution

[jira] [Commented] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-08-27 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16593824#comment-16593824 ] Rong Rong commented on FLINK-10222: --- Agree with [~fhueske]'s observation. This will cause many

[jira] [Updated] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-08-27 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-10222: -- Description: Suffix extraction in ExpressionParser.scala does not actually support extraction of

[jira] [Updated] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-08-27 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-10222: -- Description: Suffix extraction in ExpressionParser.scala does not actually support extraction of

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-08-26 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592927#comment-16592927 ] Rong Rong commented on FLINK-9172: -- [~eronwright] yes. your are right. This is the additional feature in

[jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

2018-08-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586167#comment-16586167 ] Rong Rong commented on FLINK-10172: --- Thanks for the pointer. I will take another look and add back

[jira] [Comment Edited] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

2018-08-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586092#comment-16586092 ] Rong Rong edited comment on FLINK-10172 at 8/20/18 3:33 PM: [~fhueske] yes,

[jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

2018-08-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586092#comment-16586092 ] Rong Rong commented on FLINK-10172: --- [~fhueske] yes, there were specific handling for {{ASC}} and

[jira] [Created] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

2018-08-19 Thread Rong Rong (JIRA)
Rong Rong created FLINK-10172: - Summary: Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc Key: FLINK-10172 URL: https://issues.apache.org/jira/browse/FLINK-10172 Project: Flink

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

2018-08-14 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580197#comment-16580197 ] Rong Rong commented on FLINK-: -- I do not have access to the newest SQL 2016 standard, but is

[jira] [Commented] (FLINK-10079) Automatically register sink table from external catalogs

2018-08-14 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580192#comment-16580192 ] Rong Rong commented on FLINK-10079: --- I agree we should either make the documentation more consistent,

[jira] [Comment Edited] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

2018-08-14 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578793#comment-16578793 ] Rong Rong edited comment on FLINK-10019 at 8/14/18 5:39 PM: Dug a little

[jira] [Comment Edited] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

2018-08-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578793#comment-16578793 ] Rong Rong edited comment on FLINK-10019 at 8/13/18 7:00 PM: Dug a little

[jira] [Commented] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

2018-08-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578793#comment-16578793 ] Rong Rong commented on FLINK-10019: --- Dug a little deeper in Calcite and found that in:

[jira] [Commented] (FLINK-9997) Improve Expression Reduce

2018-08-03 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568827#comment-16568827 ] Rong Rong commented on FLINK-9997: -- Thanks for the PR [~RuidongLi]. Would you mind adding more context

[jira] [Comment Edited] (FLINK-5315) Support distinct aggregations in table api

2018-08-03 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568255#comment-16568255 ] Rong Rong edited comment on FLINK-5315 at 8/3/18 2:26 PM: -- You are right, in the

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-08-03 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568255#comment-16568255 ] Rong Rong commented on FLINK-5315: -- You are right, in the actual translation {{distinct}} is translated

[jira] [Comment Edited] (FLINK-5315) Support distinct aggregations in table api

2018-08-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567666#comment-16567666 ] Rong Rong edited comment on FLINK-5315 at 8/3/18 1:25 AM: -- [~hequn8128],

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-08-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567666#comment-16567666 ] Rong Rong commented on FLINK-5315: -- [~hequn8128], [~fhueske] I am actually close to finish the

[jira] [Updated] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

2018-08-01 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-10019: -- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-9484) > Fix Composite getResultType

[jira] [Updated] (FLINK-5315) Support distinct aggregations in table api

2018-08-01 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-5315: - Description: Support distinct aggregations in Table API in the following format: For Expressions:

[jira] [Updated] (FLINK-5315) Support distinct aggregations in table api

2018-08-01 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-5315: - Description: Support distinct aggregations in Table API in the following format: For Expressions:

[jira] [Updated] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

2018-08-01 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-10019: -- Description: If explicitly return a CompositeType in {{udf.getResultType}}, will result in some

[jira] [Created] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

2018-08-01 Thread Rong Rong (JIRA)
Rong Rong created FLINK-10019: - Summary: Fix Composite getResultType of UDF cannot be chained with other operators Key: FLINK-10019 URL: https://issues.apache.org/jira/browse/FLINK-10019 Project: Flink

[jira] [Created] (FLINK-10010) Deprecate unused BaseAlignedWindowAssigner related components

2018-07-31 Thread Rong Rong (JIRA)
Rong Rong created FLINK-10010: - Summary: Deprecate unused BaseAlignedWindowAssigner related components Key: FLINK-10010 URL: https://issues.apache.org/jira/browse/FLINK-10010 Project: Flink

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563766#comment-16563766 ] Rong Rong commented on FLINK-5315: -- Actually I agree with [~hequn8128] that these are two kinds of

[jira] [Comment Edited] (FLINK-5315) Support distinct aggregations in table api

2018-07-28 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16560803#comment-16560803 ] Rong Rong edited comment on FLINK-5315 at 7/28/18 9:38 PM: --- Hmm. Yes that's

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-28 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16560803#comment-16560803 ] Rong Rong commented on FLINK-5315: -- Hmm. Yes that's true we cannot have {{a.distinct}} by itself if

[jira] [Comment Edited] (FLINK-5315) Support distinct aggregations in table api

2018-07-27 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559889#comment-16559889 ] Rong Rong edited comment on FLINK-5315 at 7/27/18 5:05 PM: --- Yes [~hequn8128].

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-27 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559889#comment-16559889 ] Rong Rong commented on FLINK-5315: -- Yes [~hequn8128]. Currently I am transferring the distinct modifier

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555898#comment-16555898 ] Rong Rong commented on FLINK-5315: -- Oops. sorry that was what I meant [~twalthr] to use

[jira] [Comment Edited] (FLINK-5315) Support distinct aggregations in table api

2018-07-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555898#comment-16555898 ] Rong Rong edited comment on FLINK-5315 at 7/25/18 4:16 PM: --- Oops. sorry that

[jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-24 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554866#comment-16554866 ] Rong Rong commented on FLINK-9294: -- Had an initial diff for discussion on what needs to be done here:

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-24 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554326#comment-16554326 ] Rong Rong commented on FLINK-5315: -- Since FLINK-8689 and FLINK-8690 has been checked in, I think we can

[jira] [Updated] (FLINK-5315) Support distinct aggregations in table api

2018-07-24 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-5315: - Issue Type: Sub-task (was: New Feature) Parent: FLINK-8688 > Support distinct aggregations in

[jira] [Assigned] (FLINK-5315) Support distinct aggregations in table api

2018-07-24 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-5315: Assignee: Rong Rong > Support distinct aggregations in table api >

[jira] [Updated] (FLINK-8691) Update table API to support distinct operator on data stream

2018-07-24 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8691: - Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-8688) > Update table API to

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-23 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

2018-07-21 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551884#comment-16551884 ] Rong Rong commented on FLINK-9134: -- Calcite 1.17 has been

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-20 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

2018-07-17 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547269#comment-16547269 ] Rong Rong commented on FLINK-8985: -- Yeah I agree, I would put more thought on this in a follow-up JIRA

[jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-11 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541084#comment-16541084 ] Rong Rong commented on FLINK-9294: -- hmm. nvm. I think I messed up with scala/java implicit conversion. I

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

2018-07-10 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539256#comment-16539256 ] Rong Rong commented on FLINK-8985: -- Thanks [~florianschmidt] for the exhausted listing for all CLI.

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-05 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16534424#comment-16534424 ] Rong Rong commented on FLINK-9294: -- Thanks [~twalthr] for the heads up. Yes I think both type extractor

<    1   2   3   4   5   >