[jira] [Created] (FLINK-12420) Add support of cache/invalidateCache for TableAPI

2019-05-06 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-12420: -- Summary: Add support of cache/invalidateCache for TableAPI Key: FLINK-12420 URL: https://issues.apache.org/jira/browse/FLINK-12420 Project: Flink Issue Type

[jira] [Created] (FLINK-12419) Add support for consuming BLOCKING_PERSISTENT ResultPartition

2019-05-06 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-12419: -- Summary: Add support for consuming BLOCKING_PERSISTENT ResultPartition Key: FLINK-12419 URL: https://issues.apache.org/jira/browse/FLINK-12419 Project: Flink

[jira] [Created] (FLINK-12406) Report BLOCKING_PERSISTENT result partition meta back to client

2019-05-05 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-12406: -- Summary: Report BLOCKING_PERSISTENT result partition meta back to client Key: FLINK-12406 URL: https://issues.apache.org/jira/browse/FLINK-12406 Project: Flink

[jira] [Created] (FLINK-12405) Introduce BLOCKING_PERSISTENT result partition type

2019-05-05 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-12405: -- Summary: Introduce BLOCKING_PERSISTENT result partition type Key: FLINK-12405 URL: https://issues.apache.org/jira/browse/FLINK-12405 Project: Flink Issue Type

[jira] [Created] (FLINK-12000) Introduce TableServiceManager to TableEnvironment

2019-03-24 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-12000: -- Summary: Introduce TableServiceManager to TableEnvironment Key: FLINK-12000 URL: https://issues.apache.org/jira/browse/FLINK-12000 Project: Flink Issue Type

[jira] [Created] (FLINK-11999) Introduce cache and invalidateCache API to Table

2019-03-24 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-11999: -- Summary: Introduce cache and invalidateCache API to Table Key: FLINK-11999 URL: https://issues.apache.org/jira/browse/FLINK-11999 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-11998) Flink Interactive Programming (Umbrella JIRA)

2019-03-24 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-11998: -- Summary: Flink Interactive Programming (Umbrella JIRA) Key: FLINK-11998 URL: https://issues.apache.org/jira/browse/FLINK-11998 Project: Flink Issue Type

Re: [DISCUSS] Support Interactive Programming in Flink Table API

2018-11-21 Thread Ruidong Li
Hi Becket, I think the Flink Service is a good abstraction, with which we can easily build Interactive Programing or some other features. We might bring the concept of 'Session', then we can think of Flink Services as system processes and user jobs as user processes, so the management of life cycl

[jira] [Created] (FLINK-10670) Fix Correlate codegen error

2018-10-24 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-10670: -- Summary: Fix Correlate codegen error Key: FLINK-10670 URL: https://issues.apache.org/jira/browse/FLINK-10670 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-10451) TableFunctionCollector should handle the life cycle of ScalarFunction

2018-09-27 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-10451: -- Summary: TableFunctionCollector should handle the life cycle of ScalarFunction Key: FLINK-10451 URL: https://issues.apache.org/jira/browse/FLINK-10451 Project: Flink

[jira] [Created] (FLINK-9997) Improve ExpressionReduce

2018-07-30 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9997: - Summary: Improve ExpressionReduce Key: FLINK-9997 URL: https://issues.apache.org/jira/browse/FLINK-9997 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9958) Fix potential NPE for delta iteration of DataSet

2018-07-25 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9958: - Summary: Fix potential NPE for delta iteration of DataSet Key: FLINK-9958 URL: https://issues.apache.org/jira/browse/FLINK-9958 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9433) SystemProcessingTimeService does not work properly

2018-05-24 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9433: - Summary: SystemProcessingTimeService does not work properly Key: FLINK-9433 URL: https://issues.apache.org/jira/browse/FLINK-9433 Project: Flink Issue Type

[jira] [Created] (FLINK-9346) Update documents for supporting intersect/except in streaming

2018-05-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9346: - Summary: Update documents for supporting intersect/except in streaming Key: FLINK-9346 URL: https://issues.apache.org/jira/browse/FLINK-9346 Project: Flink Issue

[jira] [Created] (FLINK-9345) Support EXCEPT and EXCEPT ALL for streaming

2018-05-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9345: - Summary: Support EXCEPT and EXCEPT ALL for streaming Key: FLINK-9345 URL: https://issues.apache.org/jira/browse/FLINK-9345 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9344) Support INTERSECT and INTERSECT ALL for streaming

2018-05-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9344: - Summary: Support INTERSECT and INTERSECT ALL for streaming Key: FLINK-9344 URL: https://issues.apache.org/jira/browse/FLINK-9344 Project: Flink Issue Type

[jira] [Created] (FLINK-9332) Fix Codegen error of CallGenerator

2018-05-10 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9332: - Summary: Fix Codegen error of CallGenerator Key: FLINK-9332 URL: https://issues.apache.org/jira/browse/FLINK-9332 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9216) Fix comparator violation

2018-04-18 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9216: - Summary: Fix comparator violation Key: FLINK-9216 URL: https://issues.apache.org/jira/browse/FLINK-9216 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-8868) Support Table Function as Table

2018-03-05 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8868: - Summary: Support Table Function as Table Key: FLINK-8868 URL: https://issues.apache.org/jira/browse/FLINK-8868 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8821) Fix BigDecimal divide in AvgAggFunction

2018-03-01 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8821: - Summary: Fix BigDecimal divide in AvgAggFunction Key: FLINK-8821 URL: https://issues.apache.org/jira/browse/FLINK-8821 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8617) Fix code generation bug while accessing Map type

2018-02-08 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8617: - Summary: Fix code generation bug while accessing Map type Key: FLINK-8617 URL: https://issues.apache.org/jira/browse/FLINK-8617 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8555) Fix TableFunction varargs length exceeds 254 for SQL

2018-02-03 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8555: - Summary: Fix TableFunction varargs length exceeds 254 for SQL Key: FLINK-8555 URL: https://issues.apache.org/jira/browse/FLINK-8555 Project: Flink Issue Type

[jira] [Created] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

2017-12-23 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8312: - Summary: Fix ScalarFunction varargs length exceeds 254 for SQL Key: FLINK-8312 URL: https://issues.apache.org/jira/browse/FLINK-8312 Project: Flink Issue Type

[jira] [Created] (FLINK-8301) Support Unicode in codegen for TableAPI && SQL

2017-12-21 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8301: - Summary: Support Unicode in codegen for TableAPI && SQL Key: FLINK-8301 URL: https://issues.apache.org/jira/browse/FLINK-8301 Project: Flink Is

[jira] [Created] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

2017-12-17 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8274: - Summary: Fix Java 64K method compiling limitation for CommonCalc Key: FLINK-8274 URL: https://issues.apache.org/jira/browse/FLINK-8274 Project: Flink Issue Type

[jira] [Created] (FLINK-8095) Introduce ProjectSetOpTransposeRule to Flink

2017-11-16 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8095: - Summary: Introduce ProjectSetOpTransposeRule to Flink Key: FLINK-8095 URL: https://issues.apache.org/jira/browse/FLINK-8095 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7986) Introduce FilterSetOpTransposeRule to Flink

2017-11-04 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7986: - Summary: Introduce FilterSetOpTransposeRule to Flink Key: FLINK-7986 URL: https://issues.apache.org/jira/browse/FLINK-7986 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7971) Fix potential NPE with inconsistent state

2017-11-02 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7971: - Summary: Fix potential NPE with inconsistent state Key: FLINK-7971 URL: https://issues.apache.org/jira/browse/FLINK-7971 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7776) remove duplicate records in group aggregation

2017-10-08 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7776: - Summary: remove duplicate records in group aggregation Key: FLINK-7776 URL: https://issues.apache.org/jira/browse/FLINK-7776 Project: Flink Issue Type

[jira] [Created] (FLINK-7759) Fix Bug that fieldName/functionName with prefix equals "true" or "false" can't be parsed by ExpressionParser.

2017-10-04 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7759: - Summary: Fix Bug that fieldName/functionName with prefix equals "true" or "false" can't be parsed by ExpressionParser. Key: FLINK-7759 URL: https://issues.apa

[jira] [Created] (FLINK-7621) Fix inconsistency of CaseSensitive Configuration

2017-09-14 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7621: - Summary: Fix inconsistency of CaseSensitive Configuration Key: FLINK-7621 URL: https://issues.apache.org/jira/browse/FLINK-7621 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-06 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7596: - Summary: Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType) Key: FLINK-7596 URL: https://issues.apache.org/jira/browse/FLINK-7596 Project

[jira] [Created] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7385: - Summary: Fix ArrayIndexOutOfBoundsException when object-reuse is enabled Key: FLINK-7385 URL: https://issues.apache.org/jira/browse/FLINK-7385 Project: Flink

[jira] [Created] (FLINK-7168) Add support for Table API & SQL steam-stream inner/left join

2017-07-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7168: - Summary: Add support for Table API & SQL steam-stream inner/left join Key: FLINK-7168 URL: https://issues.apache.org/jira/browse/FLINK-7168 Project: Flink I

[jira] [Created] (FLINK-7163) Make LogicalTableFunctionCall immutable

2017-07-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7163: - Summary: Make LogicalTableFunctionCall immutable Key: FLINK-7163 URL: https://issues.apache.org/jira/browse/FLINK-7163 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7014) Expose isDeterministic interface to ScalarFunction and TableFunction

2017-06-27 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7014: - Summary: Expose isDeterministic interface to ScalarFunction and TableFunction Key: FLINK-7014 URL: https://issues.apache.org/jira/browse/FLINK-7014 Project: Flink

[jira] [Created] (FLINK-6992) add support for IN, NOT IN in tableAPI

2017-06-22 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6992: - Summary: add support for IN, NOT IN in tableAPI Key: FLINK-6992 URL: https://issues.apache.org/jira/browse/FLINK-6992 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6852) Fix misuse of GCD

2017-06-05 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6852: - Summary: Fix misuse of GCD Key: FLINK-6852 URL: https://issues.apache.org/jira/browse/FLINK-6852 Project: Flink Issue Type: Improvement Reporter

[jira] [Created] (FLINK-6593) Fix Bug in ProctimeAttribute or RowtimeAttribute with join UDTF

2017-05-15 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6593: - Summary: Fix Bug in ProctimeAttribute or RowtimeAttribute with join UDTF Key: FLINK-6593 URL: https://issues.apache.org/jira/browse/FLINK-6593 Project: Flink

[jira] [Created] (FLINK-6457) Clean up ScalarFunction interface

2017-05-04 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6457: - Summary: Clean up ScalarFunction interface Key: FLINK-6457 URL: https://issues.apache.org/jira/browse/FLINK-6457 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6441) Improve the UDTF

2017-05-03 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6441: - Summary: Improve the UDTF Key: FLINK-6441 URL: https://issues.apache.org/jira/browse/FLINK-6441 Project: Flink Issue Type: Improvement Reporter

[jira] [Created] (FLINK-6334) Refactoring UDTF interface

2017-04-19 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6334: - Summary: Refactoring UDTF interface Key: FLINK-6334 URL: https://issues.apache.org/jira/browse/FLINK-6334 Project: Flink Issue Type: Improvement