[jira] [Created] (FLINK-29990) Unparsed SQL for SqlTableLike cannot be parsed correctly

Shuo Cheng created FLINK-29990: -- Summary: Unparsed SQL for SqlTableLike cannot be parsed correctly Key: FLINK-29990 URL: https://issues.apache.org/jira/browse/FLINK-29990 Project: Flink Issue

[jira] [Created] (FLINK-24762) Remove agg function: INCR_SUM

Shuo Cheng created FLINK-24762: -- Summary: Remove agg function: INCR_SUM Key: FLINK-24762 URL: https://issues.apache.org/jira/browse/FLINK-24762 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24598) Current IT case do not cover fallback path for hash aggregate

Shuo Cheng created FLINK-24598: -- Summary: Current IT case do not cover fallback path for hash aggregate Key: FLINK-24598 URL: https://issues.apache.org/jira/browse/FLINK-24598 Project: Flink

[jira] [Created] (FLINK-24048) Move changeLog inference out of optimizing phase

Shuo Cheng created FLINK-24048: -- Summary: Move changeLog inference out of optimizing phase Key: FLINK-24048 URL: https://issues.apache.org/jira/browse/FLINK-24048 Project: Flink Issue Type:

[jira] [Created] (FLINK-23962) UpdateKind trait is not propagated properly in changeLog inference for DAG optimizing

Shuo Cheng created FLINK-23962: -- Summary: UpdateKind trait is not propagated properly in changeLog inference for DAG optimizing Key: FLINK-23962 URL: https://issues.apache.org/jira/browse/FLINK-23962

[jira] [Created] (FLINK-23827) Fix ModifiedMonotonicity inference for some node

Shuo Cheng created FLINK-23827: -- Summary: Fix ModifiedMonotonicity inference for some node Key: FLINK-23827 URL: https://issues.apache.org/jira/browse/FLINK-23827 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23310) Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream

Shuo Cheng created FLINK-23310: -- Summary: Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream Key: FLINK-23310 URL: https://issues.apache.org/jira/browse/FLINK-23310

[jira] [Created] (FLINK-23136) Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public

Shuo Cheng created FLINK-23136: -- Summary: Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public Key: FLINK-23136 URL: https://issues.apache.org/jira/browse/FLINK-23136

[jira] [Created] (FLINK-23086) Add getRuntimeExecutionMode to StreamExecutionEnvironment

Shuo Cheng created FLINK-23086: -- Summary: Add getRuntimeExecutionMode to StreamExecutionEnvironment Key: FLINK-23086 URL: https://issues.apache.org/jira/browse/FLINK-23086 Project: Flink Issue

[jira] [Created] (FLINK-22586) Improve precision derivation for decimal arithmetics

Shuo Cheng created FLINK-22586: -- Summary: Improve precision derivation for decimal arithmetics Key: FLINK-22586 URL: https://issues.apache.org/jira/browse/FLINK-22586 Project: Flink Issue Type:

[jira] [Created] (FLINK-22304) Refactor some interfaces for TVF based window to improve the scalability

Shuo Cheng created FLINK-22304: -- Summary: Refactor some interfaces for TVF based window to improve the scalability Key: FLINK-22304 URL: https://issues.apache.org/jira/browse/FLINK-22304 Project: Flink

[jira] [Created] (FLINK-22148) Planner rules should use RexCall#equsls to check whether two rexCalls are equivalent

Shuo Cheng created FLINK-22148: -- Summary: Planner rules should use RexCall#equsls to check whether two rexCalls are equivalent Key: FLINK-22148 URL: https://issues.apache.org/jira/browse/FLINK-22148

[jira] [Created] (FLINK-22063) Lookup Join outputs wrong results for some scenario

Shuo Cheng created FLINK-22063: -- Summary: Lookup Join outputs wrong results for some scenario Key: FLINK-22063 URL: https://issues.apache.org/jira/browse/FLINK-22063 Project: Flink Issue Type:

[jira] [Created] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

Shuo Cheng created FLINK-21613: -- Summary: Parse Compute Column with `IN` expression throws NPE Key: FLINK-21613 URL: https://issues.apache.org/jira/browse/FLINK-21613 Project: Flink Issue Type:

[jira] [Created] (FLINK-20826) Fix bug in streaming SQL examples

Shuo Cheng created FLINK-20826: -- Summary: Fix bug in streaming SQL examples Key: FLINK-20826 URL: https://issues.apache.org/jira/browse/FLINK-20826 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-20670) Support query hints for Flink SQL

Shuo Cheng created FLINK-20670: -- Summary: Support query hints for Flink SQL Key: FLINK-20670 URL: https://issues.apache.org/jira/browse/FLINK-20670 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17651) DecomposeGroupingSetsRule generates wrong plan when there exist distinct agg and simple agg with same filter

Shuo Cheng created FLINK-17651: -- Summary: DecomposeGroupingSetsRule generates wrong plan when there exist distinct agg and simple agg with same filter Key: FLINK-17651 URL:

[jira] [Created] (FLINK-17649) Generated hash aggregate code may produce NPE when there exists an aggregate call with Filter.

Shuo Cheng created FLINK-17649: -- Summary: Generated hash aggregate code may produce NPE when there exists an aggregate call with Filter. Key: FLINK-17649 URL: https://issues.apache.org/jira/browse/FLINK-17649

[jira] [Created] (FLINK-16578) join lateral table function with condition fails with exception

Shuo Cheng created FLINK-16578: -- Summary: join lateral table function with condition fails with exception Key: FLINK-16578 URL: https://issues.apache.org/jira/browse/FLINK-16578 Project: Flink

[jira] [Created] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

Shuo Cheng created FLINK-16577: -- Summary: Exception will be thrown when computing columnInterval relmetadata in some case Key: FLINK-16577 URL: https://issues.apache.org/jira/browse/FLINK-16577 Project:

[jira] [Created] (FLINK-15537) Type of keys should be `BinaryRow` when manipulating map state with `BaseRow` as key type.

Shuo Cheng created FLINK-15537: -- Summary: Type of keys should be `BinaryRow` when manipulating map state with `BaseRow` as key type. Key: FLINK-15537 URL: https://issues.apache.org/jira/browse/FLINK-15537

[jira] [Created] (FLINK-15466) `FlinkAggregateExpandDistinctAggregatesRule` generates wrong plan for cases that have distinct aggs with filter.

Shuo Cheng created FLINK-15466: -- Summary: `FlinkAggregateExpandDistinctAggregatesRule` generates wrong plan for cases that have distinct aggs with filter. Key: FLINK-15466 URL: