[jira] [Created] (FLINK-16789) Support JMX RMI via JMXConnectorServer

2020-03-25 Thread Rong Rong (Jira)
Rong Rong created FLINK-16789: - Summary: Support JMX RMI via JMXConnectorServer Key: FLINK-16789 URL: https://issues.apache.org/jira/browse/FLINK-16789 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-16236) Fix YARNSessionFIFOSecuredITCase not loading the correct security context factory

2020-02-22 Thread Rong Rong (Jira)
Rong Rong created FLINK-16236: - Summary: Fix YARNSessionFIFOSecuredITCase not loading the correct security context factory Key: FLINK-16236 URL: https://issues.apache.org/jira/browse/FLINK-16236 Project:

[jira] [Created] (FLINK-16224) Refine Hadoop Delegation Token based testing framework

2020-02-21 Thread Rong Rong (Jira)
Rong Rong created FLINK-16224: - Summary: Refine Hadoop Delegation Token based testing framework Key: FLINK-16224 URL: https://issues.apache.org/jira/browse/FLINK-16224 Project: Flink Issue Type:

[jira] [Created] (FLINK-15561) Improve Kerberos delegation token login

2020-01-12 Thread Rong Rong (Jira)
Rong Rong created FLINK-15561: - Summary: Improve Kerberos delegation token login Key: FLINK-15561 URL: https://issues.apache.org/jira/browse/FLINK-15561 Project: Flink Issue Type: Bug

[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] [Created] (FLINK-13389) Setting DataStream return type breaks some type conversion between Table and DataStream

2019-07-23 Thread Rong Rong (JIRA)
Rong Rong created FLINK-13389: - Summary: Setting DataStream return type breaks some type conversion between Table and DataStream Key: FLINK-13389 URL: https://issues.apache.org/jira/browse/FLINK-13389 Pro

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

2019-03-15 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11936: - Summary: Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue. Key: FLINK-11936 URL: https://issues.apache.org/jira/browse/FLINK-11936 Project:

[jira] [Created] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

2019-03-15 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11935: - Summary: Remove DateTimeUtils pull-in and fix datetime casting problem Key: FLINK-11935 URL: https://issues.apache.org/jira/browse/FLINK-11935 Project: Flink Issu

[jira] [Created] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11909: - Summary: Provide default failure/timeout handling strategy for AsyncIO functions Key: FLINK-11909 URL: https://issues.apache.org/jira/browse/FLINK-11909 Project: Flink

[jira] [Created] (FLINK-11589) Introduce service provider pattern for user to dynamically load SecurityFactory classes

2019-02-12 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11589: - Summary: Introduce service provider pattern for user to dynamically load SecurityFactory classes Key: FLINK-11589 URL: https://issues.apache.org/jira/browse/FLINK-11589 Pro

[jira] [Created] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

2019-02-08 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11569: - Summary: Row type does not serialize in to readable format when invoke "toString" method Key: FLINK-11569 URL: https://issues.apache.org/jira/browse/FLINK-11569 Project: Fl

[jira] [Created] (FLINK-11456) Improve window operator with sliding window assigners

2019-01-29 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11456: - Summary: Improve window operator with sliding window assigners Key: FLINK-11456 URL: https://issues.apache.org/jira/browse/FLINK-11456 Project: Flink Issue Type: S

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

[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: Sub-tas

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

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

[jira] [Created] (FLINK-9502) Use generic parameter search for user-define functions when argument contains Object type

2018-06-01 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9502: Summary: Use generic parameter search for user-define functions when argument contains Object type Key: FLINK-9502 URL: https://issues.apache.org/jira/browse/FLINK-9502 Proje

[jira] [Created] (FLINK-9501) Allow Object.class type in user-define functions as parameter types but not result types

2018-06-01 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9501: Summary: Allow Object.class type in user-define functions as parameter types but not result types Key: FLINK-9501 URL: https://issues.apache.org/jira/browse/FLINK-9501 Projec

[jira] [Created] (FLINK-9484) Improve generic type inference for User-Defined Functions

2018-05-31 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9484: Summary: Improve generic type inference for User-Defined Functions Key: FLINK-9484 URL: https://issues.apache.org/jira/browse/FLINK-9484 Project: Flink Issue Type: I

[jira] [Created] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-05-17 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9398: Summary: Flink CLI list running job returns all jobs except in CREATE state Key: FLINK-9398 URL: https://issues.apache.org/jira/browse/FLINK-9398 Project: Flink Iss

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

2018-05-03 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9294: Summary: Improve type inference for UDFs with composite parameter or result type Key: FLINK-9294 URL: https://issues.apache.org/jira/browse/FLINK-9294 Project: Flink

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

2018-04-21 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9232: Summary: Add harness test for AggregationCodeGenerator Key: FLINK-9232 URL: https://issues.apache.org/jira/browse/FLINK-9232 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9199) SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL

2018-04-17 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9199: Summary: SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL Key: FLINK-9199 URL: https://issues.apache.org/jira/browse/FLINK-9199

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

2018-04-13 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9172: Summary: Support external catalog factory that comes default with SQL-Client Key: FLINK-9172 URL: https://issues.apache.org/jira/browse/FLINK-9172 Project: Flink Is

[jira] [Created] (FLINK-9157) Create support for commonly used external catalog

2018-04-11 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9157: Summary: Create support for commonly used external catalog Key: FLINK-9157 URL: https://issues.apache.org/jira/browse/FLINK-9157 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8739) Optimize runtime support for distinct filter to reuse same distinct accumulator for filtering

2018-02-21 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8739: Summary: Optimize runtime support for distinct filter to reuse same distinct accumulator for filtering Key: FLINK-8739 URL: https://issues.apache.org/jira/browse/FLINK-8739 P

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

2018-02-18 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8691: Summary: Update table API to support distinct operator on data stream Key: FLINK-8691 URL: https://issues.apache.org/jira/browse/FLINK-8691 Project: Flink Issue Typ

[jira] [Created] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator

2018-02-18 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8690: Summary: Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator Key: FLINK-8690 URL: https://issues.apache.org/jira/browse/FLINK-8690 P

[jira] [Created] (FLINK-8689) Add runtime support of distinct filter using MapView for GenerateAggregation

2018-02-18 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8689: Summary: Add runtime support of distinct filter using MapView for GenerateAggregation Key: FLINK-8689 URL: https://issues.apache.org/jira/browse/FLINK-8689 Project: Flink

[jira] [Created] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API

2018-02-18 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8688: Summary: Enable distinct aggregation for data stream on Table/SQL API Key: FLINK-8688 URL: https://issues.apache.org/jira/browse/FLINK-8688 Project: Flink Issue Typ

[jira] [Created] (FLINK-8215) Collections codegen exception when constructing Array or Map via SQL API

2017-12-06 Thread Rong Rong (JIRA)
Rong Rong created FLINK-8215: Summary: Collections codegen exception when constructing Array or Map via SQL API Key: FLINK-8215 URL: https://issues.apache.org/jira/browse/FLINK-8215 Project: Flink

[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] [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] [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] [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] [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] [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] [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] [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] [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-7177) [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation

2017-07-13 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7177: Summary: [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation Key: FLINK-7177 URL: https://is

[jira] [Created] (FLINK-7137) Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable

2017-07-07 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7137: Summary: Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable Key: FLINK-7137 URL: https://issues.apache.org/jira/browse/FLINK-