[
https://issues.apache.org/jira/browse/FLINK-40095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40095:
-----------------------------------
Labels: pull-request-available (was: )
> JSON aggregation functions failing in group window aggregate
> ------------------------------------------------------------
>
> Key: FLINK-40095
> URL: https://issues.apache.org/jira/browse/FLINK-40095
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 2.1.0, 2.2.0, 2.3.0
> Reporter: Xuyang Zhong
> Assignee: Xuyang Zhong
> Priority: Major
> Labels: pull-request-available
>
> This test can reproduce this bug:
> {code:java}
> @Test
> def test(): Unit = {
> util.tableEnv.executeSql("""
> |CREATE TEMPORARY TABLE kafka_raw(
> | a VARCHAR
> | ,b VARCHAR
> | ,pt AS PROCTIME()
> |)
> |WITH (
> | 'connector' = 'datagen'
> |)
> |;
> |""".stripMargin)
> println(util.verifyExplain("""
> |select
> | JSON_ARRAYAGG(ARRAY[b]) AS ecu_data
> |from kafka_raw
> |group by
> | TUMBLE(pt, INTERVAL '1' MINUTE)
> | ,a
> |;
> |""".stripMargin))
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
