Hi Robert,
could you send us the error/stacktrace that is printed?
An example how it should work is shown here:
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/UpdatingTopCityExample.java
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/GettingStartedExample.java
Regards,
Timo
On 15.01.21 16:46, Robert Cullen wrote:
I’m using a query to gather results:
|Table log_counts = tEnv.from("log_counts")
.filter($("hostname").isNotNull() .and($("hostname").isNotEqual("")))
.window(Tumble .over(lit(30).seconds()) .on($("last_updated")).as("w"))
.groupBy($("msg_id"), $("hostname"), $("w")) .select($("msg_id"),
$("hostname"), $("msg_id").count().as("cnt")); |
I’d like to iterate over the results but using this causes an error:
|log_counts.execute().collect();
|
Has there been an update in how to traverse results?
Robert Cullen
240-475-4490
