Mehul Batra created FLINK-24448: ----------------------------------- Summary: Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ Key: FLINK-24448 URL: https://issues.apache.org/jira/browse/FLINK-24448 Project: Flink Issue Type: Bug Reporter: Mehul Batra
*When I am running my code to test the connector = 'print' to see my window aggregated data it is not printing anything and when I am excluding the tumbling window it is printing data, but the same code is working with the tumble window in FLINK 1.13.1.* SQL API CONNECTORS TO REFER : tableEnv.executeSql("CREATE TABLE IF NOT EXISTS Teamtopic (\n" + " eventName String,\n" + " ingestion_time BIGINT,\n" + " t_ltz as TO_TIMESTAMP_LTZ(ingestion_time,3) , + " WATERMARK FOR t_ltz AS t_ltz - INTERVAL '5' SECOND + " as event-time attribute\n" + ") WITH (\n" + " 'connector' = 'kafka' tableEnv.executeSql("CREATE TABLE minutess (\n" + " `minute` TIMESTAMP(3),\n" + " hits BIGINT ,\n" + " type STRING\n" + ") WITH (\n" + " 'connector' = 'print' " + ")"); tableEnv.createStatementSet() .addInsertSql("INSERT INTO minutess \n" + " SELECT " + "TUMBLE_END(t_ltz,INTERVAL '1' MINUTE) AS windowmin ," + "COUNT(eventName) as hits, " + "'team_save_failed_minute_error_types' as type\n" + " FROM TeamSaveFailed\n" +" GROUP BY TUMBLE(t_ltz, INTERVAL '1' MINUTE ),eventName") .execute(); -- This message was sent by Atlassian Jira (v8.3.4#803005)