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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
42 matches
Mail list logo