Skip to content

[flink] Support hint-based watermark configuration for Flink connector#3266

Open
swuferhong wants to merge 1 commit intoapache:mainfrom
swuferhong:watermark-passed-by-option
Open

[flink] Support hint-based watermark configuration for Flink connector#3266
swuferhong wants to merge 1 commit intoapache:mainfrom
swuferhong:watermark-passed-by-option

Conversation

@swuferhong
Copy link
Copy Markdown
Contributor

Purpose

Linked issue: close #3265

  1. Introduce hint-based watermark options (scan.watermark.enabled, scan.watermark.column,
    scan.watermark.delay) that can be specified via SQL hints /*+ OPTIONS(...) */.
  2. Encapsulate all watermark-related parameters into a WatermarkContext class for better
    code cohesion and reduced constructor parameter count.
  3. Implement watermark priority resolution:
    • scan.watermark.enabled=false → disable watermark (highest priority)
    • scan.watermark.column specified → hint-based watermark overrides table-level
    • Table-level pushed watermark → fallback
    • No watermark → WatermarkStrategy.noWatermarks()
  4. Support TIMESTAMP, TIMESTAMP_LTZ, and BIGINT (epoch millis) column types.
  5. Integrate with Flink's table.exec.source.idle-timeout to handle idle splits.

Brief change log

Tests

API and Format

Documentation

@swuferhong swuferhong force-pushed the watermark-passed-by-option branch from 6018781 to ef498f7 Compare May 8, 2026 05:51
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[flink] Support hint-based watermark configuration for Flink connector

1 participant