Matan Perelmuter
08/28/2024, 7:39 PMtEnv.createTemporaryView("view", ds,
Schema.newBuilder()
.columnByExpression("proc_time", "PROCTIME()")
.columnByMetadata("rowtime", "TIMESTAMP_LTZ(3)")
.watermark("rowtime", "SOURCE_WATERMARK()")
.build()
);
I'm trying yo upgrade from flink 1.18 to 1.19 and I get an error, but from the documentation it doesn't seem like anything has changed
org.apache.flink.table.api.ValidationException: Invalid expression for watermark 'WATERMARK FOR `rowtime` AS [SOURCE_WATERMARK()]'.
any idea?Matan Perelmuter
08/29/2024, 7:36 AM<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-common</artifactId>
<version>1.19.1</version>
<scope>provided</scope>
</dependency>