[jira] [Created] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly

2017-09-23 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7678: Summary: SQL UserDefineTableFunction does not take CompositeType input correctly Key: FLINK-7678 URL: https://issues.apache.org/jira/browse/FLINK-7678 Project: Flink

[jira] [Commented] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-10-16 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206774#comment-16206774 ] Rong Rong commented on FLINK-7373: -- Hi [~fhueske], no we haven't found a great solution s

[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 Flin

[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-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&focusedCommentId=16704949#comment-16704949 ] Rong Rong commented on FLINK-8739: -- No I haven't started. please feel free to assign to

[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&focusedCommentId=16706398#comment-16706398 ] Rong Rong commented on FLINK-11010: --- Based on the discussion in the mailing list: htt

[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] [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] [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] [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&focusedCommentId=16714128#comment-16714128 ] Rong Rong commented on FLINK-11088: --- Initial investigation needs to find a way to dist

[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&focusedCommentId=16716173#comment-16716173 ] Rong Rong commented on FLINK-11081: --- +1 to this feature. Very helpful actually for lot

[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 r

[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&focusedCommentId=16634867#comment-16634867 ] Rong Rong commented on FLINK-10474: --- Voting for the first approach. I was actually wo

[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&focusedCommentId=16635666#comment-16635666 ] Rong Rong commented on FLINK-10474: --- Yes. I think having cascaded predicates are defin

[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&focusedCommentId=16638159#comment-16638159 ] Rong Rong commented on FLINK-8880: -- [~twalthr] yes aboslutely. please go ahead. > Vali

[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] [Created] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-02 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7357: Summary: HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window Key: FLINK-7357 URL: https://issues.apache.org/jira/browse/FLINK-7357 Project:

[jira] [Created] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-05 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7373: Summary: Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException Key: FLINK-7373 URL: https://issues.apache.org/jira/browse/FLINK-7373 Project:

[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7373: - Description: Using URLClassLoader to load, say from Artifactory, and instantiate UDF instances will cause

[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7373: - Description: Using URLClassLoader to load, say from Artifactory, and instantiate UDF instances will cause

[jira] [Assigned] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-7373: Assignee: Rong Rong > Using URLClassLoader to load UDF triggers HepPlanner unexpected > ClassNotFo

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-09 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120483#comment-16120483 ] Rong Rong commented on FLINK-7357: -- Seems like the logical plan generated from Having ins

[jira] [Assigned] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-09 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-7357: Assignee: Rong Rong (was: Haohui Mai) > HOP_START() HOP_END() does not work when using HAVING clau

[jira] [Commented] (FLINK-12399) FilterableTableSource does not use filters on job run

2019-09-03 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921546#comment-16921546 ] Rong Rong commented on FLINK-12399: --- Hi [~fhueske]. would you please kindly take a loo

[jira] [Comment Edited] (FLINK-12399) FilterableTableSource does not use filters on job run

2019-09-04 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833107#comment-16833107 ] Rong Rong edited comment on FLINK-12399 at 9/4/19 4:28 PM: --- Hi

[jira] [Commented] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

2019-09-18 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932569#comment-16932569 ] Rong Rong commented on FLINK-11936: --- [~danny0405] yes. I think that would be great. >

[jira] [Commented] (FLINK-10232) Add a SQL DDL

2019-05-16 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841511#comment-16841511 ] Rong Rong commented on FLINK-10232: --- Thanks Danny for bringing this up.  I think we c

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.19

2019-05-30 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852147#comment-16852147 ] Rong Rong commented on FLINK-11921: --- Hi [~twalthr], [~danny0405] and I discussed brief

[jira] [Updated] (FLINK-11921) Upgrade Calcite dependency to 1.20

2019-06-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11921: -- Summary: Upgrade Calcite dependency to 1.20 (was: Upgrade Calcite dependency to 1.19) > Upgrade Calc

[jira] [Updated] (FLINK-11921) Upgrade Calcite dependency to 1.20

2019-06-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11921: -- Description: Umbrella issue for all tasks related to the next Calcite upgrade to 1.20.x release We w

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.20

2019-06-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858835#comment-16858835 ] Rong Rong commented on FLINK-11921: --- changed title as discussed: we will skip 1.19, di

[jira] [Commented] (FLINK-12872) WindowOperator may fail with UnsupportedOperationException when merging windows

2019-06-17 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866178#comment-16866178 ] Rong Rong commented on FLINK-12872: --- This might be a [related reading|https://stackov

[jira] [Commented] (FLINK-16522) Use type hints to declare the signature of the methods

2020-04-01 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072854#comment-17072854 ] Rong Rong commented on FLINK-16522: --- Is this Jira referring to TypeChecking as well? 

[jira] [Updated] (FLINK-16522) Use type hints to declare the signature of the methods

2020-04-06 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16522: -- Description: [Type Hints|https://www.python.org/dev/peps/pep-0484/] was introduced in Python 3.5 and i

[jira] [Updated] (FLINK-16522) Use type hints to declare the signature of the methods

2020-04-06 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16522: -- Description: [Type Hints|https://www.python.org/dev/peps/pep-0484/] was introduced in Python 3.5 and i

[jira] [Commented] (FLINK-16522) Use type hints to declare the signature of the methods

2020-04-06 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076873#comment-17076873 ] Rong Rong commented on FLINK-16522: --- Thanks for the clarification. huge +1. looking fo

[jira] [Issue Comment Deleted] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

2019-12-16 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9630: - Comment: was deleted (was: Hi All, Is this a duplicate of FLINK-8497 ?) > Kafka09PartitionDiscoverer ca

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

2019-12-16 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997755#comment-16997755 ] Rong Rong commented on FLINK-9630: -- Hi All, Is this a duplicate of FLINK-8497 ? > Kafk

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

2019-12-16 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997757#comment-16997757 ] Rong Rong commented on FLINK-9630: -- Hi All, is this connected somehow with FLINK-8497?

[jira] [Assigned] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

2019-12-31 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-15451: - Assignee: Rong Rong > TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailur

[jira] [Assigned] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

2019-12-31 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-15451: - Assignee: (was: Rong Rong) > TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerPr

[jira] [Commented] (FLINK-11120) The bug of timestampadd handles time

2020-01-03 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007605#comment-17007605 ] Rong Rong commented on FLINK-11120: --- Hi [~x1q1j1] yes it will be in 1.10 release and i

[jira] [Created] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

2020-01-03 Thread Rong Rong (Jira)
Rong Rong created FLINK-15475: - Summary: Add isOutputTypeUsed() API to Transformation Key: FLINK-15475 URL: https://issues.apache.org/jira/browse/FLINK-15475 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

2020-01-03 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

2020-01-03 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

2020-01-03 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[jira] [Closed] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

2020-05-17 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-17386. - Fix Version/s: 1.11.0 Resolution: Fixed > Exception in HadoopSecurityContextFactory.createContext

[jira] [Commented] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

2020-05-17 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109703#comment-17109703 ] Rong Rong commented on FLINK-17386: --- closed via: 1892bedeea9fa118b6e3bcb572f63c2e7f6d8

[jira] [Updated] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

2020-05-17 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-17386: -- Component/s: Deployment / YARN > Exception in HadoopSecurityContextFactory.createContext while no > s

[jira] [Updated] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

2020-05-17 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-17386: -- Affects Version/s: 1.11.0 > Exception in HadoopSecurityContextFactory.createContext while no > shaded

[jira] [Created] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-10-25 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7922: Summary: leastRestrictive in FlinkTypeFactory does not resolve composite type correctly Key: FLINK-7922 URL: https://issues.apache.org/jira/browse/FLINK-7922 Project: Flink

[jira] [Updated] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-10-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7922: - Component/s: Table API & SQL > leastRestrictive in FlinkTypeFactory does not resolve composite type correc

[jira] [Updated] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-10-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7922: - Description: FlinkTypeFactory does not override the following function correctly: {code:java} def leastRes

[jira] [Updated] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-10-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7922: - Affects Version/s: 1.4.0 > leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

[jira] [Assigned] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-10-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-7922: Assignee: Rong Rong > leastRestrictive in FlinkTypeFactory does not resolve composite type correctl

[jira] [Updated] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-10-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7922: - Description: FlinkTypeFactory does not override the following function correctly: {code:scala} def leastRe

[jira] [Updated] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-10-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7922: - Description: FlinkTypeFactory does not override the following function correctly: {code:java} def leastRes

[jira] [Created] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-10-25 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7923: Summary: SQL parser exception when accessing subfields of a Composite element in an Object Array type column Key: FLINK-7923 URL: https://issues.apache.org/jira/browse/FLINK-7923

[jira] [Updated] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-10-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7923: - Component/s: Table API & SQL > SQL parser exception when accessing subfields of a Composite element in an

[jira] [Created] (FLINK-7934) Upgrade Calcite dependency to 1.15

2017-10-26 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7934: Summary: Upgrade Calcite dependency to 1.15 Key: FLINK-7934 URL: https://issues.apache.org/jira/browse/FLINK-7934 Project: Flink Issue Type: Bug Reporter

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-10-26 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220895#comment-16220895 ] Rong Rong commented on FLINK-7923: -- Done, created umbrella task for Calcite 1.15 release.

[jira] [Created] (FLINK-8038) Support MAP literal

2017-11-08 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8038: Summary: Support MAP literal Key: FLINK-8038 URL: https://issues.apache.org/jira/browse/FLINK-8038 Project: Flink Issue Type: New Feature Components: Table

[jira] [Updated] (FLINK-8038) Support MAP value constructor

2017-11-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8038: - Summary: Support MAP value constructor (was: Support MAP literal) > Support MAP value constructor > -

[jira] [Updated] (FLINK-8038) Support MAP value constructor

2017-11-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8038: - Description: Similar to https://issues.apache.org/jira/browse/FLINK-4554 We want to support Map value cons

[jira] [Updated] (FLINK-8003) Support Calcite's ROW value constructor in Flink SQL

2017-11-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8003: - Description: We want to use the row value constructor and CAST to create a named row, or even nested name

[jira] [Updated] (FLINK-8003) Support Calcite's ROW value constructor in Flink SQL

2017-11-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8003: - Description: We want to use the row value constructor and CAST to create a named row, or even nested name

[jira] [Created] (FLINK-8104) Fix Row value constructor

2017-11-18 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8104: Summary: Fix Row value constructor Key: FLINK-8104 URL: https://issues.apache.org/jira/browse/FLINK-8104 Project: Flink Issue Type: Sub-task Components: Ta

[jira] [Assigned] (FLINK-8104) Fix Row value constructor

2017-11-18 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-8104: Assignee: Rong Rong > Fix Row value constructor > - > > Key

[jira] [Created] (FLINK-8151) [Table] removing map value equality check

2017-11-25 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8151: Summary: [Table] removing map value equality check Key: FLINK-8151 URL: https://issues.apache.org/jira/browse/FLINK-8151 Project: Flink Issue Type: Bug Com

[jira] [Assigned] (FLINK-8151) [Table] removing map value equality check

2017-11-25 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-8151: Assignee: Rong Rong > [Table] removing map value equality check > -

[jira] [Updated] (FLINK-8151) [Table] Clean up Map equality check

2017-11-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8151: - Summary: [Table] Clean up Map equality check (was: [Table] removing map value equality check) > [Table]

[jira] [Updated] (FLINK-8151) [Table] Clean up Map equality check

2017-11-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8151: - Description: Following up with FLINK-8038. The equality check currently is broken. Plan to support elemen

[jira] [Updated] (FLINK-8151) [Table] Map equality check to use entrySet equality

2017-11-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8151: - Summary: [Table] Map equality check to use entrySet equality (was: [Table] Clean up Map equality check)

[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&focusedCommentId=16539256#comment-16539256 ] Rong Rong commented on FLINK-8985: -- Thanks [~florianschmidt] for the exhausted listing f

[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&focusedCommentId=16541084#comment-16541084 ] Rong Rong commented on FLINK-9294: -- hmm. nvm. I think I messed up with scala/java implic

[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&focusedCommentId=16547269#comment-16547269 ] Rong Rong commented on FLINK-8985: -- Yeah I agree, I would put more thought on this in a

[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}}*, *{{ARR

[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}}*, *{{ARR

[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}}*, *{{ARR

[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}}*, *{{ARR

[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}}*, *{{ARR

[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&focusedCommentId=16551884#comment-16551884 ] Rong Rong commented on FLINK-9134: -- Calcite 1.17 has been [released|https://mail-archiv

[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}}*, *{{ARR

[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 supp

[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-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 ta

[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&focusedCommentId=16554326#comment-16554326 ] Rong Rong commented on FLINK-5315: -- Since FLINK-8689 and FLINK-8690 has been checked in,

[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&focusedCommentId=16554866#comment-16554866 ] Rong Rong commented on FLINK-9294: -- Had an initial diff for discussion on what needs to

[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&focusedCommentId=16555898#comment-16555898 ] Rong Rong edited comment on FLINK-5315 at 7/25/18 4:16 PM: --- Oop

[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&focusedCommentId=16555898#comment-16555898 ] Rong Rong commented on FLINK-5315: -- Oops. sorry that was what I meant [~twalthr] to use

[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&focusedCommentId=16559889#comment-16559889 ] Rong Rong commented on FLINK-5315: -- Yes [~hequn8128]. Currently I am transferring the di

[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&focusedCommentId=16559889#comment-16559889 ] Rong Rong edited comment on FLINK-5315 at 7/27/18 5:05 PM: --- Yes

[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&focusedCommentId=16560803#comment-16560803 ] Rong Rong commented on FLINK-5315: -- Hmm. Yes that's true we cannot have {{a.distinct}} b

[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&focusedCommentId=16560803#comment-16560803 ] Rong Rong edited comment on FLINK-5315 at 7/28/18 9:38 PM: --- Hmm

[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&focusedCommentId=16563766#comment-16563766 ] Rong Rong commented on FLINK-5315: -- Actually I agree with [~hequn8128] that these are tw

[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 Issu

[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] [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 failu

[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: {code:

[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: {code:

  1   2   3   4   5   >