Hi, You can use watermark strategy with bounded out of orderness in DDL, please refer to [1].
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sql/create.html#watermark Regards, Roman On Tue, Feb 23, 2021 at 12:48 PM joris.vanagtmaal < [email protected]> wrote: > I worked out the rowtype input for the conversion to datastream; > > type_info = Types.ROW_NAMED(['sender', 'stw', 'time'],[Types.STRING(), > Types.DOUBLE(), Types.LONG()]) > datastream=table_env.to_append_stream(my_table, type_info) > > But if i try to assign rowtime and watermarks to the datastream and convert > it back to a table, the rowtime/watermarks either get dropped or maybe they > are not created properly. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
