mans2singh commented on a change in pull request #16587:
URL: https://github.com/apache/flink/pull/16587#discussion_r677896392
##########
File path:
flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/StreamWindowSQLExample.java
##########
@@ -79,16 +77,16 @@ public static void main(String[] args) throws Exception {
+ " COUNT(DISTINCT product) unique_products\n"
+ "FROM orders\n"
+ "GROUP BY TUMBLE(ts, INTERVAL '5' SECOND)";
- Table result = tEnv.sqlQuery(query);
- tEnv.toAppendStream(result, Row.class).print();
- // after the table program is converted to DataStream program,
- // we must use `env.execute()` to submit the job.
- env.execute("Streaming Window SQL Job");
+ tEnv.executeSql(query).print();
+ // should output;
Review comment:
@JingsongLi - I've corrected the code based on your advice. Please let
me know you have any additional comments. Thanks again for your
review/comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
