tableEnv.fromDataStream(xxxStream).addColumns('processTime.proctime)
Приведенный выше код будет выдавать исключение:
org.apache.flink.table.api.ValidationException: Window properties can only be used on windowed tables.
, но это будет работать
tableEnv.fromDataStream(xxxStream, 'id, ......, 'processTime.proctime)
Но я должен повторить все столбцы таким образом.