[jira] [Commented] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ
[ https://issues.apache.org/jira/browse/FLINK-24448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427204#comment-17427204 ] Mehul Batra commented on FLINK-24448: - Hi, [~twalthr] can you please help me understand this as we really want to move to flink 1.14 due to the job name inconsistency in 1.13.1 > 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 > Components: Table SQL / Runtime >Reporter: Mehul Batra >Priority: Major > > *When I am running my code to test the connector = 'print' to see my window > aggregated data it is not printing anything in version 1.14.0 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)
[jira] [Updated] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ
[ https://issues.apache.org/jira/browse/FLINK-24448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mehul Batra updated FLINK-24448: Description: *When I am running my code to test the connector = 'print' to see my window aggregated data it is not printing anything in version 1.14.0 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(); was: *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(); > 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 > Components: Table SQL / Runtime >Reporter: Mehul Batra >Priority: Major > > *When I am running my code to test the connector = 'print' to see my window > aggregated data it is not printing anything in version 1.14.0 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)
[jira] [Commented] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ
[ https://issues.apache.org/jira/browse/FLINK-24448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426555#comment-17426555 ] Mehul Batra commented on FLINK-24448: - Version 1.14.0 > 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 > Components: Table SQL / Runtime >Reporter: Mehul Batra >Priority: Major > > *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)
[jira] [Created] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ
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)