[
https://issues.apache.org/jira/browse/FLINK-40095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18096390#comment-18096390
]
Xuyang Zhong commented on FLINK-40095:
--------------------------------------
Merged into master: 7f707f3ece7c0fa5bf8bb44f9db499dc73d932ec
> 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
> Fix For: 2.4.0
>
>
> 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)
