swapna267 opened a new pull request, #12697: URL: https://github.com/apache/iceberg/pull/12697
Backport changes in https://github.com/apache/iceberg/pull/12191 to 1.18,1.19 Iceberg Source to support Source Watermark, so it can be used in Flink WINDOW functions. https://github.com/apache/flink/blob/release-1.18/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsSourceWatermark.java enables Flink to rely on the watermark strategy provided by the ScanTableSource itself. ``` CREATE TABLE table_wm ( eventTS AS CAST(t1 AS TIMESTAMP(3)), WATERMARK FOR eventTS AS SOURCE_WATERMARK() ) WITH ( 'watermark-column'='t1' ) LIKE iceberg_catalog.db.table; ``` **Reference:** https://github.com/apache/iceberg/issues/10219 https://github.com/apache/iceberg/pull/9346 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org
