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 Components: Table SQL / API Affects Versions: 1.14.0 Reporter: JING ZHANG
There is a syntax mistake in session Window TVF in FLINK-23543. For example, the following SQL has syntax mistake. {code:java} """ |SELECT | a, | window_start, | window_end, | count(*), | sum(d), | max(d) filter (where b > 1000), | count(distinct c) AS uv |FROM TABLE( | SESSION( | TABLE MyTable, | DESCRIPTOR(proctime), | INTERVAL '5' MINUTE)) |GROUP BY a, window_start, window_end """.stripMargin {code} It should updated to the following SQL, while partition key (a) should be moved into SESSION Window TVF based on Calcite [SESSION window TVF|https://calcite.apache.org/docs/reference.html#session]. {code:java} val sql = """ |SELECT | a, | window_start, | window_end, | count(*), | sum(d), | max(d) filter (where b > 1000), | count(distinct c) AS uv |FROM TABLE( | SESSION( | TABLE MyTable, | DESCRIPTOR(proctime), | DESCRIPTOR(a) | INTERVAL '5' MINUTE)) |GROUP BY a, window_start, window_end """.stripMargin{code} To fix the bug, we only need update Session Window TVF syntax, we don't need update the operator part. Besides, we should check group keys of window aggregate should only contain window_start, window_end, partition_key. group keys could not contain other fields. -- This message was sent by Atlassian Jira (v8.3.4#803005)