Xuyang Zhong created FLINK-40095:
------------------------------------
Summary: 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.3.0, 2.2.0, 2.1.0
Reporter: Xuyang Zhong
Assignee: Xuyang Zhong
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)
