[
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)
