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

2021-10-11 Thread Mehul Batra (Jira) 


[ 
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] [Commented] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ

2021-10-09 Thread Mehul Batra (Jira) 


[ 
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] [Commented] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ

2021-10-07 Thread Jark Wu (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-24448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425501#comment-17425501
 ] 

Jark Wu commented on FLINK-24448:
-

Which version doesn't work? 

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