Re: Flink 1.13 Tumble Window Setting Time Attribute Column

and provide your program. > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/concepts/time_attributes/#processing-time > [2] > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/concepts/time_attributes/#event-time > > Be

Flink 1.13 Tumble Window Setting Time Attribute Column

Hi, I'm upgrading a repository from Flink 1.11 to Flink 1.13. I have Flink SQL command that used to do tumbling windows using the following in the GROUP BY clause: SELECT ... FROM ... GROUP BY TUMBLE(proctime, INTERVAL '1' MINUTE) However now, it gives me the error: org.apache.flink.table.api.T

Table Aggregate - Flink SQL

I want to create a Python UDF for a table aggregate function. The documentation explains this, and how to use its results by calling the flatAggregate function. However, I would not like to use the Table API. I would like to call the table aggregate function from Flink SQL. I'm using Flink 1.13. My