Hi, I have this code which create view from a data...
# troubleshooting
m
Hi, I have this code which create view from a datastream
Copy code
tEnv.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
Copy code
org.apache.flink.table.api.ValidationException: Invalid expression for watermark 'WATERMARK FOR `rowtime` AS [SOURCE_WATERMARK()]'.
any idea?
fixed by adding to my pom.xml although I didn't had to do it so far
Copy code
<dependency>
     <groupId>org.apache.flink</groupId>
     <artifactId>flink-table-common</artifactId>
     <version>1.19.1</version>
     <scope>provided</scope>
</dependency>