[jira] [Created] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

2021-01-09 Thread Andy (Jira)
Andy created FLINK-20909: Summary: MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate. Key: FLINK-20909 URL: https://iss

[jira] [Created] (FLINK-20910) Remove restriction on StreamPhysicalGroupWindowAggregate that StreamPhysicalGroupWindowAggregate only support insert-only input node

2021-01-10 Thread Andy (Jira)
Andy created FLINK-20910: Summary: Remove restriction on StreamPhysicalGroupWindowAggregate that StreamPhysicalGroupWindowAggregate only support insert-only input node Key: FLINK-20910 URL: https://issues.apache.org/jira/

[jira] [Created] (FLINK-21253) Support grouping set/cube/rollup syntax in WindowAggregate

2021-02-03 Thread Andy (Jira)
Andy created FLINK-21253: Summary: Support grouping set/cube/rollup syntax in WindowAggregate Key: FLINK-21253 URL: https://issues.apache.org/jira/browse/FLINK-21253 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

2021-02-05 Thread Andy (Jira)
Andy created FLINK-21301: Summary: Decouple window aggregate allow lateness with state ttl configuration Key: FLINK-21301 URL: https://issues.apache.org/jira/browse/FLINK-21301 Project: Flink Issue

[jira] [Created] (FLINK-21302) Fix NPE when use row_number() in over agg

2021-02-05 Thread Andy (Jira)
Andy created FLINK-21302: Summary: Fix NPE when use row_number() in over agg Key: FLINK-21302 URL: https://issues.apache.org/jira/browse/FLINK-21302 Project: Flink Issue Type: New Feature C

[jira] [Created] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread Andy (Jira)
Andy created FLINK-21482: Summary: Support grouping set syntax for WindowAggregate Key: FLINK-21482 URL: https://issues.apache.org/jira/browse/FLINK-21482 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-21893) A ValidationException will be thrown out when deriveRowType of Rank if partition key is an expression result of Input Node.

2021-03-21 Thread Andy (Jira)
Andy created FLINK-21893: Summary: A ValidationException will be thrown out when deriveRowType of Rank if partition key is an expression result of Input Node. Key: FLINK-21893 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

2021-03-30 Thread Andy (Jira)
Andy created FLINK-22038: Summary: Update TopN node to be without rowNumber if rowNumber field is projected out after TopN Key: FLINK-22038 URL: https://issues.apache.org/jira/browse/FLINK-22038 Project: Flin

[jira] [Created] (FLINK-22098) Fix bug for window join: plan test is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread Andy (Jira)
Andy created FLINK-22098: Summary: Fix bug for window join: plan test is wrong if join condition contain 'IS NOT DISTINCT FROM' Key: FLINK-22098 URL: https://issues.apache.org/jira/browse/FLINK-22098 Project:

[jira] [Created] (FLINK-22099) Fix bug for semi/anti window join.

2021-04-01 Thread Andy (Jira)
Andy created FLINK-22099: Summary: Fix bug for semi/anti window join. Key: FLINK-22099 URL: https://issues.apache.org/jira/browse/FLINK-22099 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-22680) An IndexOutOfBoundsException is thrown out after apply WatermarkAssignerChangelogNormalizeTransposeRule

2021-05-17 Thread Andy (Jira)
Andy created FLINK-22680: Summary: An IndexOutOfBoundsException is thrown out after apply WatermarkAssignerChangelogNormalizeTransposeRule Key: FLINK-22680 URL: https://issues.apache.org/jira/browse/FLINK-22680

[jira] [Created] (FLINK-22714) Simplify `StreamPhysicalWindowTableFunction` to `StreamPhysicalWindowAssignerFunction` which is only a simple window assigner table function if successor node with `Wind

2021-05-19 Thread Andy (Jira)
Andy created FLINK-22714: Summary: Simplify `StreamPhysicalWindowTableFunction` to `StreamPhysicalWindowAssignerFunction` which is only a simple window assigner table function if successor node with `WindowAttachedWindowingStrategy` in planner

[jira] [Created] (FLINK-22715) Implement streaming window assigner tablefunction operator

2021-05-19 Thread Andy (Jira)
Andy created FLINK-22715: Summary: Implement streaming window assigner tablefunction operator Key: FLINK-22715 URL: https://issues.apache.org/jira/browse/FLINK-22715 Project: Flink Issue Type: Sub-ta