Jing Zhang created FLINK-28741:
--
Summary: Unexpected result if insert 'false' to boolean column
Key: FLINK-28741
URL: https://issues.apache.org/jira/browse/FLINK-28741
Project: Flink
Issue
Jing Zhang created FLINK-28397:
--
Summary: Source Supports Speculative Execution For Batch Job
Key: FLINK-28397
URL: https://issues.apache.org/jira/browse/FLINK-28397
Project: Flink
Issue Type:
Jing Zhang created FLINK-28003:
--
Summary: 'pos ' field would be updated to 'POSITION' when use
SqlClient
Key: FLINK-28003
URL: https://issues.apache.org/jira/browse/FLINK-28003
Project: Flink
Jing Zhang created FLINK-27086:
--
Summary: Add a QA about how to handle exception when use hive
parser in hive dialect document
Key: FLINK-27086
URL: https://issues.apache.org/jira/browse/FLINK-27086
Jing Zhang created FLINK-27020:
--
Summary: use hive dialect in SqlClient would thrown an error based
on 1.15 version
Key: FLINK-27020
URL: https://issues.apache.org/jira/browse/FLINK-27020
Project: Flink
Jing Zhang created FLINK-27019:
--
Summary: use hive dialect in SqlClient would thrown an error based
on 1.15 version
Key: FLINK-27019
URL: https://issues.apache.org/jira/browse/FLINK-27019
Project: Flink
Jing Zhang created FLINK-25645:
--
Summary: UnsupportedOperationException would thrown out when hash
shuffle by a field with array type
Key: FLINK-25645
URL: https://issues.apache.org/jira/browse/FLINK-25645
Jing Zhang created FLINK-25641:
--
Summary: Unexpected aggregate plan after load hive module
Key: FLINK-25641
URL: https://issues.apache.org/jira/browse/FLINK-25641
Project: Flink
Issue Type:
Jing Zhang created FLINK-25605:
--
Summary: Batch get statistics of multiple partitions instead of
get one by one
Key: FLINK-25605
URL: https://issues.apache.org/jira/browse/FLINK-25605
Project: Flink
Jing Zhang created FLINK-25604:
--
Summary: Remove useless aggregate function
Key: FLINK-25604
URL: https://issues.apache.org/jira/browse/FLINK-25604
Project: Flink
Issue Type: Sub-task
Jing Zhang created FLINK-25596:
--
Summary: Specify hash/sortmerge join in SQL hint
Key: FLINK-25596
URL: https://issues.apache.org/jira/browse/FLINK-25596
Project: Flink
Issue Type: Sub-task
Jing Zhang created FLINK-25595:
--
Summary: Specify hash/sort aggregate strategy in SQL hint
Key: FLINK-25595
URL: https://issues.apache.org/jira/browse/FLINK-25595
Project: Flink
Issue Type:
Jing Zhang created FLINK-25594:
--
Summary: Take parquet metadata into consideration when source is
parquet files
Key: FLINK-25594
URL: https://issues.apache.org/jira/browse/FLINK-25594
Project: Flink
Jing Zhang created FLINK-25593:
--
Summary: A redundant scan could be skipped if it is an input of
join and the other input is empty after partition prune
Key: FLINK-25593
URL:
Jing Zhang created FLINK-25592:
--
Summary: Improvement of parser, optimizer and execution for Flink
Batch SQL
Key: FLINK-25592
URL: https://issues.apache.org/jira/browse/FLINK-25592
Project: Flink
Jing Zhang created FLINK-25258:
--
Summary: Update log4j2 version to avoid
Key: FLINK-25258
URL: https://issues.apache.org/jira/browse/FLINK-25258
Project: Flink
Issue Type: Bug
Affects
JING ZHANG created FLINK-24772:
--
Summary: Update user document for individual window table-valued
function
Key: FLINK-24772
URL: https://issues.apache.org/jira/browse/FLINK-24772
Project: Flink
JING ZHANG created FLINK-24760:
--
Summary: Update user document for batch window tvf
Key: FLINK-24760
URL: https://issues.apache.org/jira/browse/FLINK-24760
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-24708:
--
Summary: `ConvertToNotInOrInRule` has a bug which leads to wrong
result
Key: FLINK-24708
URL: https://issues.apache.org/jira/browse/FLINK-24708
Project: Flink
JING ZHANG created FLINK-24656:
--
Summary: Add user document for Window Deduplication
Key: FLINK-24656
URL: https://issues.apache.org/jira/browse/FLINK-24656
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-24501:
--
Summary: Unexpected behavior of cumulate window aggregate for late
event after recover from sp/cp
Key: FLINK-24501
URL: https://issues.apache.org/jira/browse/FLINK-24501
JING ZHANG created FLINK-24168:
--
Summary: Rowtime type is not correct for windowTableFunction or
OverAggregate on Match because the output type does not updated after input
rowtime attribute changed from rowtime to rowtime_ltz
Key:
JING ZHANG created FLINK-24024:
--
Summary: Fix syntax mistake in session Window TVF
Key: FLINK-24024
URL: https://issues.apache.org/jira/browse/FLINK-24024
Project: Flink
Issue Type: Bug
JING ZHANG created FLINK-24002:
--
Summary: Support count window with the window TVF in planner
Key: FLINK-24002
URL: https://issues.apache.org/jira/browse/FLINK-24002
Project: Flink
Issue Type:
JING ZHANG created FLINK-24001:
--
Summary: Support evaluating individual window table-valued
function in runtime
Key: FLINK-24001
URL: https://issues.apache.org/jira/browse/FLINK-24001
Project: Flink
JING ZHANG created FLINK-24000:
--
Summary: window aggregate support allow lateness
Key: FLINK-24000
URL: https://issues.apache.org/jira/browse/FLINK-24000
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23999:
--
Summary: Support evaluating individual window table-valued function
Key: FLINK-23999
URL: https://issues.apache.org/jira/browse/FLINK-23999
Project: Flink
Issue
JING ZHANG created FLINK-23997:
--
Summary: SQL windowing table-valued function improvement
Key: FLINK-23997
URL: https://issues.apache.org/jira/browse/FLINK-23997
Project: Flink
Issue Type: Bug
JING ZHANG created FLINK-23886:
--
Summary: An exception is thrown out when recover job timers from
savepoint file
Key: FLINK-23886
URL: https://issues.apache.org/jira/browse/FLINK-23886
Project: Flink
JING ZHANG created FLINK-23751:
--
Summary: Testing Window Top-N after Windowing TVF
Key: FLINK-23751
URL: https://issues.apache.org/jira/browse/FLINK-23751
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23750:
--
Summary: Add document for Window Top-N after Windowing TVF
Key: FLINK-23750
URL: https://issues.apache.org/jira/browse/FLINK-23750
Project: Flink
Issue Type:
JING ZHANG created FLINK-23749:
--
Summary: Testing Window Join
Key: FLINK-23749
URL: https://issues.apache.org/jira/browse/FLINK-23749
Project: Flink
Issue Type: Sub-task
Components:
JING ZHANG created FLINK-23748:
--
Summary: Testing session window
Key: FLINK-23748
URL: https://issues.apache.org/jira/browse/FLINK-23748
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23747:
--
Summary: Teting Window TVF offset
Key: FLINK-23747
URL: https://issues.apache.org/jira/browse/FLINK-23747
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23687:
--
Summary: Add Sql query hint to enable LookupJoin shuffle by join
key of left input
Key: FLINK-23687
URL: https://issues.apache.org/jira/browse/FLINK-23687
Project: Flink
JING ZHANG created FLINK-23650:
--
Summary: A sql contains 'Case when' could not run successfully
when choose Hive Dialect
Key: FLINK-23650
URL: https://issues.apache.org/jira/browse/FLINK-23650
Project:
JING ZHANG created FLINK-23638:
--
Summary: Field names are not kept after apply
ProjectToWindowRule#ProjectToLogicalProjectAndWindowRule
Key: FLINK-23638
URL: https://issues.apache.org/jira/browse/FLINK-23638
JING ZHANG created FLINK-23582:
--
Summary: Add document for session window
Key: FLINK-23582
URL: https://issues.apache.org/jira/browse/FLINK-23582
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23565:
--
Summary: Window TVF Supports session window in runtime
Key: FLINK-23565
URL: https://issues.apache.org/jira/browse/FLINK-23565
Project: Flink
Issue Type:
JING ZHANG created FLINK-23554:
--
Summary: SqlCli throws an exception and hang
Key: FLINK-23554
URL: https://issues.apache.org/jira/browse/FLINK-23554
Project: Flink
Issue Type: Bug
JING ZHANG created FLINK-23544:
--
Summary: Window TVF Supports session window
Key: FLINK-23544
URL: https://issues.apache.org/jira/browse/FLINK-23544
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23543:
--
Summary: Window TVF Supports session window
Key: FLINK-23543
URL: https://issues.apache.org/jira/browse/FLINK-23543
Project: Flink
Issue Type: Bug
JING ZHANG created FLINK-23414:
--
Summary: Split Match_ROWTIME return type converter into a
separator class
Key: FLINK-23414
URL: https://issues.apache.org/jira/browse/FLINK-23414
Project: Flink
JING ZHANG created FLINK-23413:
--
Summary: Port RelTimeIndicatorConverter from SCALA to JAVA
Key: FLINK-23413
URL: https://issues.apache.org/jira/browse/FLINK-23413
Project: Flink
Issue Type:
JING ZHANG created FLINK-23287:
--
Summary: Create user document for Window Join in SQL
Key: FLINK-23287
URL: https://issues.apache.org/jira/browse/FLINK-23287
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23286:
--
Summary: Create user document for Window Join in SQL
Key: FLINK-23286
URL: https://issues.apache.org/jira/browse/FLINK-23286
Project: Flink
Issue Type:
JING ZHANG created FLINK-23282:
--
Summary: Compile error in `Streaming Java` module:
MailboxProcessor.java:[217,13]
Key: FLINK-23282
URL: https://issues.apache.org/jira/browse/FLINK-23282
Project: Flink
JING ZHANG created FLINK-23247:
--
Summary: Materialize rowtime attribute fields of regular join's
inputs
Key: FLINK-23247
URL: https://issues.apache.org/jira/browse/FLINK-23247
Project: Flink
JING ZHANG created FLINK-23246:
--
Summary: Refactor the time indicator materialization
Key: FLINK-23246
URL: https://issues.apache.org/jira/browse/FLINK-23246
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23245:
--
Summary: Materialize rowtime attribute fields of regular join's
inputs
Key: FLINK-23245
URL: https://issues.apache.org/jira/browse/FLINK-23245
Project: Flink
JING ZHANG created FLINK-23244:
--
Summary: Refactor the time indicator materialization
Key: FLINK-23244
URL: https://issues.apache.org/jira/browse/FLINK-23244
Project: Flink
Issue Type:
JING ZHANG created FLINK-23079:
--
Summary: HiveTableSinkITCase fails
Key: FLINK-23079
URL: https://issues.apache.org/jira/browse/FLINK-23079
Project: Flink
Issue Type: Bug
Components:
JING ZHANG created FLINK-23055:
--
Summary: Add document for Window TVF offset
Key: FLINK-23055
URL: https://issues.apache.org/jira/browse/FLINK-23055
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23023:
--
Summary: Support offset in window TVF
Key: FLINK-23023
URL: https://issues.apache.org/jira/browse/FLINK-23023
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23015:
--
Summary: Implement streaming window Deduplicate operator
Key: FLINK-23015
URL: https://issues.apache.org/jira/browse/FLINK-23015
Project: Flink
Issue Type:
JING ZHANG created FLINK-23014:
--
Summary: Support streaming window Deduplicate in planner
Key: FLINK-23014
URL: https://issues.apache.org/jira/browse/FLINK-23014
Project: Flink
Issue Type:
Jing Zhang created FLINK-15077:
--
Summary: Support Semi/Anti LookupJoin in Blink planner
Key: FLINK-15077
URL: https://issues.apache.org/jira/browse/FLINK-15077
Project: Flink
Issue Type: Bug
Jing Zhang created FLINK-14946:
--
Summary: Retraction infer would result in bad plan under corner
case in blink planner
Key: FLINK-14946
URL: https://issues.apache.org/jira/browse/FLINK-14946
Project:
Jing Zhang created FLINK-14875:
--
Summary: Set Unmodifiable collection serializer of Kryo in Flink
code
Key: FLINK-14875
URL: https://issues.apache.org/jira/browse/FLINK-14875
Project: Flink
Jing Zhang created FLINK-13582:
--
Summary: Improve the implementation of LISTAGG in Blink planner to
remove delimiter from state
Key: FLINK-13582
URL: https://issues.apache.org/jira/browse/FLINK-13582
Jing Zhang created FLINK-13529:
--
Summary: Verify and correct agg function's semantic for Blink
planner
Key: FLINK-13529
URL: https://issues.apache.org/jira/browse/FLINK-13529
Project: Flink
Jing Zhang created FLINK-13509:
--
Summary: Support `is not distinct from ` and similar syntax in
LookupJoin
Key: FLINK-13509
URL: https://issues.apache.org/jira/browse/FLINK-13509
Project: Flink
Jing Zhang created FLINK-13503:
--
Summary: Correct the behavior of `JDBCLookupFunction`
Key: FLINK-13503
URL: https://issues.apache.org/jira/browse/FLINK-13503
Project: Flink
Issue Type: Task
Jing Zhang created FLINK-13433:
--
Summary: Do not fetch data from LookupableTableSource if the
JoinKey in left side of LookupJoin contains null value
Key: FLINK-13433
URL:
Jing Zhang created FLINK-13321:
--
Summary: Join a udf with constant arguments or without argument in
TableAPI query of Blink Planner does not work now
Key: FLINK-13321
URL:
Jing Zhang created FLINK-13314:
--
Summary: Correct resultType of some PlannerExpression when
operands contains DecimalTypeInfo or BigDecimalTypeInfo in Blink planner
Key: FLINK-13314
URL:
Jing Zhang created FLINK-13301:
--
Summary: Some PlannerExpression resultType is not consistent with
Calcite Type inference
Key: FLINK-13301
URL: https://issues.apache.org/jira/browse/FLINK-13301
Project:
Jing Zhang created FLINK-13218:
--
Summary: '*.count not supported in TableApi query
Key: FLINK-13218
URL: https://issues.apache.org/jira/browse/FLINK-13218
Project: Flink
Issue Type: Task
Jing Zhang created FLINK-13213:
--
Summary: MinIdleStateRetentionTime/MaxIdleStateRetentionTime in
TableConfig will be removed after call toAppendStream/toRetractStream without
QueryConfig parameters
Key: FLINK-13213
Jing Zhang created FLINK-13071:
--
Summary: QueryOperationConverter in Blink planner support add
kinds of QueryOperations.
Key: FLINK-13071
URL: https://issues.apache.org/jira/browse/FLINK-13071
Project:
Jing Zhang created FLINK-12810:
--
Summary: Support to run a TableAPI query like 'table.select('a,
'b, 'c)'
Key: FLINK-12810
URL: https://issues.apache.org/jira/browse/FLINK-12810
Project: Flink
Jing Zhang created FLINK-12496:
--
Summary: Support translation from StreamExecGroupWindowAggregate
to StreamTransformation.
Key: FLINK-12496
URL: https://issues.apache.org/jira/browse/FLINK-12496
Jing Zhang created FLINK-12374:
--
Summary: Support translation from
StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation.
Key: FLINK-12374
URL: https://issues.apache.org/jira/browse/FLINK-12374
Jing Zhang created FLINK-12348:
--
Summary: Use TableConfig in api module to replace TableConfig in
blink-planner module.
Key: FLINK-12348
URL: https://issues.apache.org/jira/browse/FLINK-12348
Project:
Jing Zhang created FLINK-12307:
--
Summary: Support translation from StreamExecWindowJoin to
StreamTransformation.
Key: FLINK-12307
URL: https://issues.apache.org/jira/browse/FLINK-12307
Project: Flink
Jing Zhang created FLINK-12208:
--
Summary: Introduce Sort / TemporalSort / SortLimit/ Limit
operators for blink streaming runtime
Key: FLINK-12208
URL: https://issues.apache.org/jira/browse/FLINK-12208
Jing Zhang created FLINK-12017:
--
Summary: Support to run a sql query : 'SELECT * FROM source'
Key: FLINK-12017
URL: https://issues.apache.org/jira/browse/FLINK-12017
Project: Flink
Issue Type:
Jing Zhang created FLINK-11993:
--
Summary: Introduce partitionable filesystem sink
Key: FLINK-11993
URL: https://issues.apache.org/jira/browse/FLINK-11993
Project: Flink
Issue Type: Task
Jing Zhang created FLINK-11975:
--
Summary: Support to run a sql query : 'SELECT * FROM (VALUES (1,
2, 3)) T(a, b, c)'
Key: FLINK-11975
URL: https://issues.apache.org/jira/browse/FLINK-11975
Project:
Jing Zhang created FLINK-11946:
--
Summary: Introduce Exec nodes
Key: FLINK-11946
URL: https://issues.apache.org/jira/browse/FLINK-11946
Project: Flink
Issue Type: Task
Reporter: Jing
80 matches
Mail list logo
