Hi Lec, You can only define `assignTimestampAndWatermark` on DataStream, so you have to convert `Table` into DataStream first. If the DataStream already has been assigned watermark, then the new `assignTimestampAndWatermark` will override the previous watermark.
Best, Jark On Thu, 23 Apr 2020 at 22:03, lec ssmi <shicheng31...@gmail.com> wrote: > can assignTimestampAndWatermark again on a watermarked table？ > > Jark Wu <imj...@gmail.com> 于 2020年4月23日周四 20:18写道： > >> Hi Matyas, >> >> You can create a new table based on the existing table using LIKE syntax >> [1] in the upcoming 1.11 version, e.g. >> >> CREATE TABLE derived_table ( >> WATERMARK FOR tstmp AS tsmp - INTERVAL '5' SECOND >> ) LIKE base_table; >> >> For now, maybe you have to manually create a new table using full DDL. >> >> Best, >> Jark >> >> [1]: >> https://cwiki.apache.org/confluence/display/FLINK/FLIP-110%3A+Support+LIKE+clause+in+CREATE+TABLE >> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-110:+Support+LIKE+clause+in+CREATE+TABLE> >> >> 2020年4月23日 17:35，Őrhidi Mátyás <matyas.orh...@gmail.com> 写道： >> >> Dear Community, >> >> is it possible to define WATERMARKS in SQL queries/views? We have a read >> only catalog implementation and we would like to assign WMs to the tables >> somehow. >> >> Thanks, >> Matyas >> >> >>
