[jira] [Created] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ

["Mehul Batra (Jira)" <ji...@apache.org>]

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)