Skip to content

Conversation

@swapna267
Copy link
Contributor

Backport changes in #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:
#10219
#9346

@github-actions github-actions bot added the flink label Mar 31, 2025
@swapna267
Copy link
Contributor Author

@pvary this is a clean backport. There were some checks not related to my code were failing in first commit, so had to make dummy commit to re-trigger tests.

@pvary pvary merged commit 2e1577e into apache:main Apr 1, 2025
20 checks passed
@pvary
Copy link
Contributor

pvary commented Apr 1, 2025

Merged to main.
Thanks for the PR @swapna267!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants