[jira] [Created] (FLINK-35792) Sorting by proctime does not work in rank

xuyang created FLINK-35792: -- Summary: Sorting by proctime does not work in rank Key: FLINK-35792 URL: https://issues.apache.org/jira/browse/FLINK-35792 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35271) Add doc for syntax `describe job 'xxx'`

xuyang created FLINK-35271: -- Summary: Add doc for syntax `describe job 'xxx'` Key: FLINK-35271 URL: https://issues.apache.org/jira/browse/FLINK-35271 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34381) `RelDataType#getFullTypeString` should be used to print in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString`

xuyang created FLINK-34381: -- Summary: `RelDataType#getFullTypeString` should be used to print in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString` Key: FLINK-34381 URL:

[jira] [Created] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

xuyang created FLINK-34380: -- Summary: Strange RowKind and records about intermediate output when using minibatch join Key: FLINK-34380 URL: https://issues.apache.org/jira/browse/FLINK-34380 Project: Flink

[jira] [Created] (FLINK-34378) Minibatch join disrupted the original order of input records

xuyang created FLINK-34378: -- Summary: Minibatch join disrupted the original order of input records Key: FLINK-34378 URL: https://issues.apache.org/jira/browse/FLINK-34378 Project: Flink Issue

[jira] [Created] (FLINK-34375) Complete work for syntax `DESCRIBE EXTENDED tableName`

xuyang created FLINK-34375: -- Summary: Complete work for syntax `DESCRIBE EXTENDED tableName` Key: FLINK-34375 URL: https://issues.apache.org/jira/browse/FLINK-34375 Project: Flink Issue Type:

[jira] [Created] (FLINK-34374) Complete work for syntax `DESCRIBE EXTENDED DATABASE databaseName`

xuyang created FLINK-34374: -- Summary: Complete work for syntax `DESCRIBE EXTENDED DATABASE databaseName` Key: FLINK-34374 URL: https://issues.apache.org/jira/browse/FLINK-34374 Project: Flink

[jira] [Created] (FLINK-34373) Complete work for syntax `DESCRIBE DATABASE databaseName`

xuyang created FLINK-34373: -- Summary: Complete work for syntax `DESCRIBE DATABASE databaseName` Key: FLINK-34373 URL: https://issues.apache.org/jira/browse/FLINK-34373 Project: Flink Issue Type:

[jira] [Created] (FLINK-34372) Complete work for syntax `DESCRIBE CATALOG catalogName`

xuyang created FLINK-34372: -- Summary: Complete work for syntax `DESCRIBE CATALOG catalogName` Key: FLINK-34372 URL: https://issues.apache.org/jira/browse/FLINK-34372 Project: Flink Issue Type:

[jira] [Created] (FLINK-34370) [Umbrella] Complete work about enhanced Flink SQL DDL

xuyang created FLINK-34370: -- Summary: [Umbrella] Complete work about enhanced Flink SQL DDL Key: FLINK-34370 URL: https://issues.apache.org/jira/browse/FLINK-34370 Project: Flink Issue Type:

[jira] [Created] (FLINK-34353) A strange exception will be thrown if minibatch size is not set while using mini-batch join

xuyang created FLINK-34353: -- Summary: A strange exception will be thrown if minibatch size is not set while using mini-batch join Key: FLINK-34353 URL: https://issues.apache.org/jira/browse/FLINK-34353

[jira] [Created] (FLINK-34348) Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

xuyang created FLINK-34348: -- Summary: Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input Key: FLINK-34348 URL: https://issues.apache.org/jira/browse/FLINK-34348 Project:

[jira] [Created] (FLINK-34346) Release Testing: Verify FLINK-24024 Support session Window TVF

xuyang created FLINK-34346: -- Summary: Release Testing: Verify FLINK-24024 Support session Window TVF Key: FLINK-34346 URL: https://issues.apache.org/jira/browse/FLINK-34346 Project: Flink Issue

[jira] [Created] (FLINK-34338) An exception is thrown when some named params change order when using window tvf

xuyang created FLINK-34338: -- Summary: An exception is thrown when some named params change order when using window tvf Key: FLINK-34338 URL: https://issues.apache.org/jira/browse/FLINK-34338 Project: Flink

[jira] [Created] (FLINK-34335) Query hints in RexSubQuery could not be printed

xuyang created FLINK-34335: -- Summary: Query hints in RexSubQuery could not be printed Key: FLINK-34335 URL: https://issues.apache.org/jira/browse/FLINK-34335 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34323) Session window tvf failed when using named params

xuyang created FLINK-34323: -- Summary: Session window tvf failed when using named params Key: FLINK-34323 URL: https://issues.apache.org/jira/browse/FLINK-34323 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34315) Forcibly disable window join, window rank and window deduplicate optimization when using session window tvf

xuyang created FLINK-34315: -- Summary: Forcibly disable window join, window rank and window deduplicate optimization when using session window tvf Key: FLINK-34315 URL: https://issues.apache.org/jira/browse/FLINK-34315

[jira] [Created] (FLINK-34313) Update doc about session window tvf

xuyang created FLINK-34313: -- Summary: Update doc about session window tvf Key: FLINK-34313 URL: https://issues.apache.org/jira/browse/FLINK-34313 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34271) Fix the unstable test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

xuyang created FLINK-34271: -- Summary: Fix the unstable test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT Key: FLINK-34271 URL: https://issues.apache.org/jira/browse/FLINK-34271 Project: Flink

[jira] [Created] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

xuyang created FLINK-34254: -- Summary: `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions Key: FLINK-34254 URL: https://issues.apache.org/jira/browse/FLINK-34254 Project: Flink

[jira] [Created] (FLINK-34238) In streaming mode, redundant exchange nodes can be optimally deleted in some cases

xuyang created FLINK-34238: -- Summary: In streaming mode, redundant exchange nodes can be optimally deleted in some cases Key: FLINK-34238 URL: https://issues.apache.org/jira/browse/FLINK-34238 Project:

[jira] [Created] (FLINK-34235) Not using Optional as input arguments in QueryHintsResolver

xuyang created FLINK-34235: -- Summary: Not using Optional as input arguments in QueryHintsResolver Key: FLINK-34235 URL: https://issues.apache.org/jira/browse/FLINK-34235 Project: Flink Issue Type:

[jira] [Created] (FLINK-34175) When meeting WindowedSliceAssigner, slice window agg registers an wrong timestamp timer

xuyang created FLINK-34175: -- Summary: When meeting WindowedSliceAssigner, slice window agg registers an wrong timestamp timer Key: FLINK-34175 URL: https://issues.apache.org/jira/browse/FLINK-34175

[jira] [Created] (FLINK-34141) Bash exited with code '143'

xuyang created FLINK-34141: -- Summary: Bash exited with code '143' Key: FLINK-34141 URL: https://issues.apache.org/jira/browse/FLINK-34141 Project: Flink Issue Type: Bug Components: Build

[jira] [Created] (FLINK-34140) Rename WindowContext in window

xuyang created FLINK-34140: -- Summary: Rename WindowContext in window Key: FLINK-34140 URL: https://issues.apache.org/jira/browse/FLINK-34140 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34139) The window assigner should not reveal its event time or process time at the interface level.

xuyang created FLINK-34139: -- Summary: The window assigner should not reveal its event time or process time at the interface level. Key: FLINK-34139 URL: https://issues.apache.org/jira/browse/FLINK-34139

[jira] [Created] (FLINK-34138) Improve the interface about MergeCallback in window

xuyang created FLINK-34138: -- Summary: Improve the interface about MergeCallback in window Key: FLINK-34138 URL: https://issues.apache.org/jira/browse/FLINK-34138 Project: Flink Issue Type:

[jira] [Created] (FLINK-34100) Support session window table function without pulling up with window agg

xuyang created FLINK-34100: -- Summary: Support session window table function without pulling up with window agg Key: FLINK-34100 URL: https://issues.apache.org/jira/browse/FLINK-34100 Project: Flink

[jira] [Created] (FLINK-34049) Refactor classes related to window TVF aggregation to prepare for non-aligned windows

xuyang created FLINK-34049: -- Summary: Refactor classes related to window TVF aggregation to prepare for non-aligned windows Key: FLINK-34049 URL: https://issues.apache.org/jira/browse/FLINK-34049 Project:

[jira] [Created] (FLINK-34048) Support Session Window Aggregate in table runtime

xuyang created FLINK-34048: -- Summary: Support Session Window Aggregate in table runtime Key: FLINK-34048 URL: https://issues.apache.org/jira/browse/FLINK-34048 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34039) The session group window agg operator does not split the session window when processing retrace records.

xuyang created FLINK-34039: -- Summary: The session group window agg operator does not split the session window when processing retrace records. Key: FLINK-34039 URL: https://issues.apache.org/jira/browse/FLINK-34039

[jira] [Created] (FLINK-34034) When kv hint and list hint handle duplicate query hints, the results are different.

xuyang created FLINK-34034: -- Summary: When kv hint and list hint handle duplicate query hints, the results are different. Key: FLINK-34034 URL: https://issues.apache.org/jira/browse/FLINK-34034 Project:

[jira] [Created] (FLINK-33941) Use field index instead of field name about window time column

xuyang created FLINK-33941: -- Summary: Use field index instead of field name about window time column Key: FLINK-33941 URL: https://issues.apache.org/jira/browse/FLINK-33941 Project: Flink Issue

[jira] [Created] (FLINK-33928) Should not throw exception while creating view with specify field names even if the query conflicts in field names

xuyang created FLINK-33928: -- Summary: Should not throw exception while creating view with specify field names even if the query conflicts in field names Key: FLINK-33928 URL:

[jira] [Created] (FLINK-33878) Many Keyed Operator extends `TableStreamOperator` which is marked without key.

xuyang created FLINK-33878: -- Summary: Many Keyed Operator extends `TableStreamOperator` which is marked without key. Key: FLINK-33878 URL: https://issues.apache.org/jira/browse/FLINK-33878 Project: Flink

[jira] [Created] (FLINK-33760) Group Window agg has different result when only consuming -D records while using or not using minibatch

xuyang created FLINK-33760: -- Summary: Group Window agg has different result when only consuming -D records while using or not using minibatch Key: FLINK-33760 URL: https://issues.apache.org/jira/browse/FLINK-33760

[jira] [Created] (FLINK-33740) Introduce a flip to list the supported sql patterns

xuyang created FLINK-33740: -- Summary: Introduce a flip to list the supported sql patterns Key: FLINK-33740 URL: https://issues.apache.org/jira/browse/FLINK-33740 Project: Flink Issue Type:

[jira] [Created] (FLINK-33583) Support state ttl hint for join

xuyang created FLINK-33583: -- Summary: Support state ttl hint for join Key: FLINK-33583 URL: https://issues.apache.org/jira/browse/FLINK-33583 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33489) LISTAGG with generating partial-final agg will case wrong result

xuyang created FLINK-33489: -- Summary: LISTAGG with generating partial-final agg will case wrong result Key: FLINK-33489 URL: https://issues.apache.org/jira/browse/FLINK-33489 Project: Flink Issue

[jira] [Created] (FLINK-33396) The table alias when using join hints should be removed in the final plan

xuyang created FLINK-33396: -- Summary: The table alias when using join hints should be removed in the final plan Key: FLINK-33396 URL: https://issues.apache.org/jira/browse/FLINK-33396 Project: Flink

[jira] [Created] (FLINK-33395) The join hint doesn't work when appears in subquery

xuyang created FLINK-33395: -- Summary: The join hint doesn't work when appears in subquery Key: FLINK-33395 URL: https://issues.apache.org/jira/browse/FLINK-33395 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29280) Hint will not be propagated in subquery

xuyang created FLINK-29280: -- Summary: Hint will not be propagated in subquery Key: FLINK-29280 URL: https://issues.apache.org/jira/browse/FLINK-29280 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29221) Adding join hint in sql may cause imcompatible state

xuyang created FLINK-29221: -- Summary: Adding join hint in sql may cause imcompatible state Key: FLINK-29221 URL: https://issues.apache.org/jira/browse/FLINK-29221 Project: Flink Issue Type:

[jira] [Created] (FLINK-29081) Join Hint cannot be identified by lowercase

xuyang created FLINK-29081: -- Summary: Join Hint cannot be identified by lowercase Key: FLINK-29081 URL: https://issues.apache.org/jira/browse/FLINK-29081 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29074) use 'add jar' in sql client throws "Could not find any jdbc dialect factories that implement"

xuyang created FLINK-29074: -- Summary: use 'add jar' in sql client throws "Could not find any jdbc dialect factories that implement" Key: FLINK-29074 URL: https://issues.apache.org/jira/browse/FLINK-29074

[jira] [Created] (FLINK-28969) Release Testing: Verify FLIP-229 Join Hints for Flink SQL Batch

xuyang created FLINK-28969: -- Summary: Release Testing: Verify FLIP-229 Join Hints for Flink SQL Batch Key: FLINK-28969 URL: https://issues.apache.org/jira/browse/FLINK-28969 Project: Flink Issue

[jira] [Created] (FLINK-28682) support join hint in flink batch

xuyang created FLINK-28682: -- Summary: support join hint in flink batch Key: FLINK-28682 URL: https://issues.apache.org/jira/browse/FLINK-28682 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28678) Support SQL hint for Filter, SetOp, Sort, Window, Values

xuyang created FLINK-28678: -- Summary: Support SQL hint for Filter, SetOp, Sort, Window, Values Key: FLINK-28678 URL: https://issues.apache.org/jira/browse/FLINK-28678 Project: Flink Issue Type: New

[jira] [Created] (FLINK-27876) Error side is chosen in BatchPhysicalHashJoinRule when the join is Semi or Anti

xuyang created FLINK-27876: -- Summary: Error side is chosen in BatchPhysicalHashJoinRule when the join is Semi or Anti Key: FLINK-27876 URL: https://issues.apache.org/jira/browse/FLINK-27876 Project: Flink

[jira] [Created] (FLINK-27853) FLIP-229: Introduces Join Hint for Flink SQL Batch Job

xuyang created FLINK-27853: -- Summary: FLIP-229: Introduces Join Hint for Flink SQL Batch Job Key: FLINK-27853 URL: https://issues.apache.org/jira/browse/FLINK-27853 Project: Flink Issue Type: New

[jira] [Created] (FLINK-27851) Join can't access the pk from source table

xuyang created FLINK-27851: -- Summary: Join can't access the pk from source table Key: FLINK-27851 URL: https://issues.apache.org/jira/browse/FLINK-27851 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27247) when add numeric casting rules, some logics are lost

xuyang created FLINK-27247: -- Summary: when add numeric casting rules, some logics are lost Key: FLINK-27247 URL: https://issues.apache.org/jira/browse/FLINK-27247 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27239) rewrite PreValidateReWriter from scala to java

xuyang created FLINK-27239: -- Summary: rewrite PreValidateReWriter from scala to java Key: FLINK-27239 URL: https://issues.apache.org/jira/browse/FLINK-27239 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26975) TableTestBase will not generate exec node tree after generating rel node tree

xuyang created FLINK-26975: -- Summary: TableTestBase will not generate exec node tree after generating rel node tree Key: FLINK-26975 URL: https://issues.apache.org/jira/browse/FLINK-26975 Project: Flink

[jira] [Created] (FLINK-24914) Support implicit type conversion in SQL like "select int_field = varchar_field"

xuyang created FLINK-24914: -- Summary: Support implicit type conversion in SQL like "select int_field = varchar_field" Key: FLINK-24914 URL: https://issues.apache.org/jira/browse/FLINK-24914 Project: Flink

[jira] [Created] (FLINK-24835) "group by" in the interval join will throw a exception

xuyang created FLINK-24835: -- Summary: "group by" in the interval join will throw a exception Key: FLINK-24835 URL: https://issues.apache.org/jira/browse/FLINK-24835 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24754) PushDownSepcs are better to be print by a clear order.

xuyang created FLINK-24754: -- Summary: PushDownSepcs are better to be print by a clear order. Key: FLINK-24754 URL: https://issues.apache.org/jira/browse/FLINK-24754 Project: Flink Issue Type:

[jira] [Created] (FLINK-24632) "where ... in(..)" has wrong result

xuyang created FLINK-24632: -- Summary: "where ... in(..)" has wrong result Key: FLINK-24632 URL: https://issues.apache.org/jira/browse/FLINK-24632 Project: Flink Issue Type: Bug