sunjincheng created FLINK-5795:
--
Summary: Improve “UDTF" to support with parameter constructor
Key: FLINK-5795
URL: https://issues.apache.org/jira/browse/FLINK-5795
Project: Flink
Issue Type:
sunjincheng created FLINK-5803:
--
Summary: Add [partitioned] processing time OVER RANGE BETWEEN
UNBOUNDED PRECEDING aggregation to SQL
Key: FLINK-5803
URL: https://issues.apache.org/jira/browse/FLINK-5803
sunjincheng created FLINK-5804:
--
Summary: Add [non-partitioned] processing time OVER RANGE BETWEEN
UNBOUNDED PRECEDING aggregation to SQL
Key: FLINK-5804
URL: https://issues.apache.org/jira/browse/FLINK-5804
sunjincheng created FLINK-5776:
--
Summary: Improve XXMapRunner support create instance by carrying
constructor parameters
Key: FLINK-5776
URL: https://issues.apache.org/jira/browse/FLINK-5776
Project:
sunjincheng created FLINK-5105:
--
Summary: Improve ReduceState: value put into ReducingState should
always be a copy
Key: FLINK-5105
URL: https://issues.apache.org/jira/browse/FLINK-5105
Project: Flink
sunjincheng created FLINK-5106:
--
Summary: improving IncrementalAggregateReduceFunction
Key: FLINK-5106
URL: https://issues.apache.org/jira/browse/FLINK-5106
Project: Flink
Issue Type:
sunjincheng created FLINK-5386:
--
Summary: Refacturing Window Clause
Key: FLINK-5386
URL: https://issues.apache.org/jira/browse/FLINK-5386
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-6204:
--
Summary: Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING
aggregation to SQL
Key: FLINK-6204
URL: https://issues.apache.org/jira/browse/FLINK-6204
Project: Flink
sunjincheng created FLINK-6219:
--
Summary: Add a state backend which supports sorting
Key: FLINK-6219
URL: https://issues.apache.org/jira/browse/FLINK-6219
Project: Flink
Issue Type: New Feature
sunjincheng created FLINK-6200:
--
Summary: Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING
aggregation to SQL
Key: FLINK-6200
URL: https://issues.apache.org/jira/browse/FLINK-6200
Project: Flink
sunjincheng created FLINK-6228:
--
Summary: Integrating the OVER windows in the Table API
Key: FLINK-6228
URL: https://issues.apache.org/jira/browse/FLINK-6228
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6074:
--
Summary: Fix
Key: FLINK-6074
URL: https://issues.apache.org/jira/browse/FLINK-6074
Project: Flink
Issue Type: Bug
Reporter: sunjincheng
--
sunjincheng created FLINK-6138:
--
Summary: Improve
UnboundedNonPartitionedProcessingOverProcessFunction
Key: FLINK-6138
URL: https://issues.apache.org/jira/browse/FLINK-6138
Project: Flink
sunjincheng created FLINK-6097:
--
Summary: Guaranteed the order of the extracted field references
Key: FLINK-6097
URL: https://issues.apache.org/jira/browse/FLINK-6097
Project: Flink
Issue Type:
sunjincheng created FLINK-6055:
--
Summary: Supported setting timers on a Non-Keyed Stream
Key: FLINK-6055
URL: https://issues.apache.org/jira/browse/FLINK-6055
Project: Flink
Issue Type: New
sunjincheng created FLINK-6259:
--
Summary: Fix a small spelling error
Key: FLINK-6259
URL: https://issues.apache.org/jira/browse/FLINK-6259
Project: Flink
Issue Type: Bug
Components:
sunjincheng created FLINK-6266:
--
Summary: Remove the useless import in FlinkRelBuilder
Key: FLINK-6266
URL: https://issues.apache.org/jira/browse/FLINK-6266
Project: Flink
Issue Type:
sunjincheng created FLINK-6267:
--
Summary: Remove the useless import in FlinkRelBuilder
Key: FLINK-6267
URL: https://issues.apache.org/jira/browse/FLINK-6267
Project: Flink
Issue Type:
sunjincheng created FLINK-6304:
--
Summary: Clear a lot of useless import
Key: FLINK-6304
URL: https://issues.apache.org/jira/browse/FLINK-6304
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-6018:
--
Summary: Minor improvements about
`AbstractKeyedStateBackend#getPartitionedState` method
Key: FLINK-6018
URL: https://issues.apache.org/jira/browse/FLINK-6018
Project:
sunjincheng created FLINK-5957:
--
Summary: Remove `getAccumulatorType` method from
`AggregateFunction`
Key: FLINK-5957
URL: https://issues.apache.org/jira/browse/FLINK-5957
Project: Flink
sunjincheng created FLINK-5995:
--
Summary: Get a Exception when creating the ListStateDescriptor
with a TypeInformation
Key: FLINK-5995
URL: https://issues.apache.org/jira/browse/FLINK-5995
Project:
sunjincheng created FLINK-6145:
--
Summary: Add [non-partitioned] event time OVER ROWS BETWEEN x
PRECEDING aggregation to SQL
Key: FLINK-6145
URL: https://issues.apache.org/jira/browse/FLINK-6145
Project:
sunjincheng created FLINK-7342:
--
Summary: Add support for Regular Expression Operators (RLIKE)
Key: FLINK-7342
URL: https://issues.apache.org/jira/browse/FLINK-7342
Project: Flink
Issue Type:
sunjincheng created FLINK-7358:
--
Summary: Add implicitly converts support for User-defined function
Key: FLINK-7358
URL: https://issues.apache.org/jira/browse/FLINK-7358
Project: Flink
Issue
sunjincheng created FLINK-7464:
--
Summary: Add useful build-in Aggregate function into TabalAPI
Key: FLINK-7464
URL: https://issues.apache.org/jira/browse/FLINK-7464
Project: Flink
Issue Type:
sunjincheng created FLINK-7465:
--
Summary: Add build-in BloomFilterCount on TableAPI
Key: FLINK-7465
URL: https://issues.apache.org/jira/browse/FLINK-7465
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-7205:
--
Summary: Add UUID supported in TableAPI/SQL
Key: FLINK-7205
URL: https://issues.apache.org/jira/browse/FLINK-7205
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-7101:
--
Summary: Fix Non-windowed group-aggregate error when using
`minIdleStateRetentionTime` config and retract agg
Key: FLINK-7101
URL: https://issues.apache.org/jira/browse/FLINK-7101
sunjincheng created FLINK-6392:
--
Summary: Change the alias of Window from optional to essential.
Key: FLINK-6392
URL: https://issues.apache.org/jira/browse/FLINK-6392
Project: Flink
Issue Type:
sunjincheng created FLINK-6406:
--
Summary: Cleanup useless import
Key: FLINK-6406
URL: https://issues.apache.org/jira/browse/FLINK-6406
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-7471:
--
Summary: Improve bounded OVER support non-retract method AGG
Key: FLINK-7471
URL: https://issues.apache.org/jira/browse/FLINK-7471
Project: Flink
Issue Type:
sunjincheng created FLINK-6583:
--
Summary: Enable QueryConfig in count base GroupWindow
Key: FLINK-6583
URL: https://issues.apache.org/jira/browse/FLINK-6583
Project: Flink
Issue Type: New
sunjincheng created FLINK-6618:
--
Summary: Fix `GroupWindow` JAVA logical plans not consistent with
SCALA logical plans.
Key: FLINK-6618
URL: https://issues.apache.org/jira/browse/FLINK-6618
Project:
sunjincheng created FLINK-6617:
--
Summary: Improve JAVA and SCALA logical plans consistent test
Key: FLINK-6617
URL: https://issues.apache.org/jira/browse/FLINK-6617
Project: Flink
Issue Type:
sunjincheng created FLINK-6619:
--
Summary: Check Table API & SQL support for 1.3.0 RC01 Release
Key: FLINK-6619
URL: https://issues.apache.org/jira/browse/FLINK-6619
Project: Flink
Issue Type:
sunjincheng created FLINK-6598:
--
Summary: Fix `DataStreamGroupAggregateRule` matches error.
Key: FLINK-6598
URL: https://issues.apache.org/jira/browse/FLINK-6598
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-6597:
--
Summary: Cleanup WindowOperatorTest useless imports
Key: FLINK-6597
URL: https://issues.apache.org/jira/browse/FLINK-6597
Project: Flink
Issue Type: Test
sunjincheng created FLINK-6959:
--
Summary: Add documentation for SQL OVER windows
Key: FLINK-6959
URL: https://issues.apache.org/jira/browse/FLINK-6959
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-6960:
--
Summary: Add E(2.7182818284590452354),PI(3.14159265358979323846)
supported in SQL
Key: FLINK-6960
URL: https://issues.apache.org/jira/browse/FLINK-6960
Project: Flink
sunjincheng created FLINK-6973:
--
Summary: Add L/RPAD supported in TableAPI
Key: FLINK-6973
URL: https://issues.apache.org/jira/browse/FLINK-6973
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6974:
--
Summary: Add BIN supported in TableAPI
Key: FLINK-6974
URL: https://issues.apache.org/jira/browse/FLINK-6974
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6975:
--
Summary: Add CONCAT/CONCAT_WS supported in TableAPI
Key: FLINK-6975
URL: https://issues.apache.org/jira/browse/FLINK-6975
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6978:
--
Summary: Add documentation for Register User-Defined Functions.
Key: FLINK-6978
URL: https://issues.apache.org/jira/browse/FLINK-6978
Project: Flink
Issue Type:
sunjincheng created FLINK-6977:
--
Summary: Add MD5/SHA1/SHA2 supported in TableAPI
Key: FLINK-6977
URL: https://issues.apache.org/jira/browse/FLINK-6977
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-7020:
--
Summary: Upgrade calcite to calcite 1.13
Key: FLINK-7020
URL: https://issues.apache.org/jira/browse/FLINK-7020
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-6650:
--
Summary: Fix Non-windowed group-aggregate error when using
append-table mode.
Key: FLINK-6650
URL: https://issues.apache.org/jira/browse/FLINK-6650
Project: Flink
sunjincheng created FLINK-6649:
--
Summary: Improve Non-window group aggregate with configurable
`earlyFire`.
Key: FLINK-6649
URL: https://issues.apache.org/jira/browse/FLINK-6649
Project: Flink
sunjincheng created FLINK-6686:
--
Summary: Improve UDXF(UDF,UDTF,UDAF) test case
Key: FLINK-6686
URL: https://issues.apache.org/jira/browse/FLINK-6686
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6736:
--
Summary: Fix UDTF codegen bug when window follow by join( UDTF)
Key: FLINK-6736
URL: https://issues.apache.org/jira/browse/FLINK-6736
Project: Flink
Issue Type:
sunjincheng created FLINK-6740:
--
Summary: Fix "parameterTypeEquals" method error.
Key: FLINK-6740
URL: https://issues.apache.org/jira/browse/FLINK-6740
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6632:
--
Summary: Fix parameter case sensitive error for test
passing/rejecting filter API
Key: FLINK-6632
URL: https://issues.apache.org/jira/browse/FLINK-6632
Project: Flink
sunjincheng created FLINK-6760:
--
Summary: Fix OverWindowTest alias test error
Key: FLINK-6760
URL: https://issues.apache.org/jira/browse/FLINK-6760
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6813:
--
Summary: Add DATEDIFF as build-in scalar function
Key: FLINK-6813
URL: https://issues.apache.org/jira/browse/FLINK-6813
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6811:
--
Summary: Add DATEADD/DATESUB/DATEDIFF as build-in scalar function
Key: FLINK-6811
URL: https://issues.apache.org/jira/browse/FLINK-6811
Project: Flink
Issue
sunjincheng created FLINK-6839:
--
Summary: Improve SQL OVER alias When only one OVER window agg in
selection.
Key: FLINK-6839
URL: https://issues.apache.org/jira/browse/FLINK-6839
Project: Flink
sunjincheng created FLINK-6837:
--
Summary: Fix a small error message bug, And improve some message
info.
Key: FLINK-6837
URL: https://issues.apache.org/jira/browse/FLINK-6837
Project: Flink
sunjincheng created FLINK-6841:
--
Summary: using TableSourceTable for both Stream and Batch OR
remove useless import
Key: FLINK-6841
URL: https://issues.apache.org/jira/browse/FLINK-6841
Project: Flink
sunjincheng created FLINK-6847:
--
Summary: Add TIMESTAMPDIFF supported in TableAPI
Key: FLINK-6847
URL: https://issues.apache.org/jira/browse/FLINK-6847
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6845:
--
Summary: Cleanup "println(StreamITCase.testResults)" call in test
case
Key: FLINK-6845
URL: https://issues.apache.org/jira/browse/FLINK-6845
Project: Flink
sunjincheng created FLINK-6924:
--
Summary: ADD LOG/LPAD/RPAD/BIN supported in TableAPI
Key: FLINK-6924
URL: https://issues.apache.org/jira/browse/FLINK-6924
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6925:
--
Summary: Add CONCAT/CONCAT_WS supported in SQL
Key: FLINK-6925
URL: https://issues.apache.org/jira/browse/FLINK-6925
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6891:
--
Summary: Add LOG supported in SQL
Key: FLINK-6891
URL: https://issues.apache.org/jira/browse/FLINK-6891
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6892:
--
Summary: Add LPAD supported in SQL
Key: FLINK-6892
URL: https://issues.apache.org/jira/browse/FLINK-6892
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6893:
--
Summary: Add BIN supported in SQL
Key: FLINK-6893
URL: https://issues.apache.org/jira/browse/FLINK-6893
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6895:
--
Summary: Add STR_TO_DATE supported in SQL
Key: FLINK-6895
URL: https://issues.apache.org/jira/browse/FLINK-6895
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6894:
--
Summary: Add DATE_FORMAT supported in SQL
Key: FLINK-6894
URL: https://issues.apache.org/jira/browse/FLINK-6894
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-6941:
--
Summary: Selecting window start / end on over window causes field
not resolve exception
Key: FLINK-6941
URL: https://issues.apache.org/jira/browse/FLINK-6941
Project:
sunjincheng created FLINK-6942:
--
Summary: Add a document for the FLINK-6810 related scalar functions
Key: FLINK-6942
URL: https://issues.apache.org/jira/browse/FLINK-6942
Project: Flink
Issue
sunjincheng created FLINK-6886:
--
Summary: Fix Timestamp field can not be selected in event time
case when toDataStream[T], `T` not a `Row` Type.
Key: FLINK-6886
URL: https://issues.apache.org/jira/browse/FLINK-6886
sunjincheng created FLINK-6479:
--
Summary: Hot fix FLINK-5906 bug
Key: FLINK-6479
URL: https://issues.apache.org/jira/browse/FLINK-6479
Project: Flink
Issue Type: Bug
Components: Table
sunjincheng created FLINK-6426:
--
Summary: Correct the method parameter type error in the
group-window table API document
Key: FLINK-6426
URL: https://issues.apache.org/jira/browse/FLINK-6426
Project:
sunjincheng created FLINK-6462:
--
Summary: Add requires over indicators for UDAF
Key: FLINK-6462
URL: https://issues.apache.org/jira/browse/FLINK-6462
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-6851:
--
Summary: Improve built-in scalar function when upgrade calcite
version to 1.13
Key: FLINK-6851
URL: https://issues.apache.org/jira/browse/FLINK-6851
Project: Flink
sunjincheng created FLINK-7025:
--
Summary: Using NullByteKeySelector for Unbounded ProcTime
NonPartitioned Over
Key: FLINK-7025
URL: https://issues.apache.org/jira/browse/FLINK-7025
Project: Flink
sunjincheng created FLINK-7024:
--
Summary: Add supported for selecting window proctime/rowtime on
row-based Tumble/Slide window
Key: FLINK-7024
URL: https://issues.apache.org/jira/browse/FLINK-7024
sunjincheng created FLINK-7618:
--
Summary: Add BINARY supported in FlinkTypeFactory
Key: FLINK-7618
URL: https://issues.apache.org/jira/browse/FLINK-7618
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-7558:
--
Summary: Improve SQL ValidationException message.
Key: FLINK-7558
URL: https://issues.apache.org/jira/browse/FLINK-7558
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-7485:
--
Summary: Using DataView interface to improve
(MIN/MAX)WithRetractAggFunction.
Key: FLINK-7485
URL: https://issues.apache.org/jira/browse/FLINK-7485
Project: Flink
sunjincheng created FLINK-7572:
--
Summary: Improve TableSchema ValidationException message.
Key: FLINK-7572
URL: https://issues.apache.org/jira/browse/FLINK-7572
Project: Flink
Issue Type:
sunjincheng created FLINK-8323:
--
Summary: Fix Mod scala function bug
Key: FLINK-8323
URL: https://issues.apache.org/jira/browse/FLINK-8323
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-8355:
--
Summary: DataSet Should not union a NULL row for AGG without GROUP
BY clause.
Key: FLINK-8355
URL: https://issues.apache.org/jira/browse/FLINK-8355
Project: Flink
sunjincheng created FLINK-8325:
--
Summary: Add support for constant parameters in GROUP WINDOW
aggregate
Key: FLINK-8325
URL: https://issues.apache.org/jira/browse/FLINK-8325
Project: Flink
sunjincheng created FLINK-10639:
---
Summary: Fix java syntax error in document
Key: FLINK-10639
URL: https://issues.apache.org/jira/browse/FLINK-10639
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-10676:
---
Summary: Add 'as' method for OverWindowWithOrderBy in Java API
Key: FLINK-10676
URL: https://issues.apache.org/jira/browse/FLINK-10676
Project: Flink
Issue
sunjincheng created FLINK-10819:
---
Summary: The instability problem of CI,
JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.
Key: FLINK-10819
URL:
sunjincheng created FLINK-10834:
---
Summary: TableAPI flatten calculated value error
Key: FLINK-10834
URL: https://issues.apache.org/jira/browse/FLINK-10834
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-10875:
---
Summary: Add `toTableWithTimestamp` method in
`DataStreamConversions`
Key: FLINK-10875
URL: https://issues.apache.org/jira/browse/FLINK-10875
Project: Flink
sunjincheng created FLINK-11242:
---
Summary: The predicate `'o_c_id === Null(Types.STRING)` not work
in TableAPI
Key: FLINK-11242
URL: https://issues.apache.org/jira/browse/FLINK-11242
Project: Flink
sunjincheng created FLINK-11243:
---
Summary: GroupBy udf() can not be select in TableAPI
Key: FLINK-11243
URL: https://issues.apache.org/jira/browse/FLINK-11243
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11246:
---
Summary: Fix distinct AGG visibility issues
Key: FLINK-11246
URL: https://issues.apache.org/jira/browse/FLINK-11246
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11220:
---
Summary: Can not Select row time field in JOIN query
Key: FLINK-11220
URL: https://issues.apache.org/jira/browse/FLINK-11220
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11223:
---
Summary: Time zone problem of row time field
Key: FLINK-11223
URL: https://issues.apache.org/jira/browse/FLINK-11223
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11123:
---
Summary: Improve ml quick start doc
Key: FLINK-11123
URL: https://issues.apache.org/jira/browse/FLINK-11123
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-11178:
---
Summary: Check flink-test module for 1.7.1-rc2
Key: FLINK-11178
URL: https://issues.apache.org/jira/browse/FLINK-11178
Project: Flink
Issue Type: Test
sunjincheng created FLINK-11181:
---
Summary: SimpleRecoveryITCaseBase test error
Key: FLINK-11181
URL: https://issues.apache.org/jira/browse/FLINK-11181
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-11179:
---
Summary:
JoinCancelingITCase#testCancelSortMatchWhileDoingHeavySorting test error
Key: FLINK-11179
URL: https://issues.apache.org/jira/browse/FLINK-11179
Project:
sunjincheng created FLINK-11182:
---
Summary: JobManagerHACheckpointRecoveryITCase need be improved
Key: FLINK-11182
URL: https://issues.apache.org/jira/browse/FLINK-11182
Project: Flink
Issue
sunjincheng created FLINK-11180:
---
Summary:
ProcessFailureCancelingITCase#testCancelingOnProcessFailure
Key: FLINK-11180
URL: https://issues.apache.org/jira/browse/FLINK-11180
Project: Flink
sunjincheng created FLINK-11091:
---
Summary: Clear the use of deprecated methods of KeyedStream in
table operators
Key: FLINK-11091
URL: https://issues.apache.org/jira/browse/FLINK-11091
Project: Flink
1 - 100 of 186 matches
Mail list logo
