Skip to content

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

@swuferhong

Description

@swuferhong

Search before asking

  • I searched in the issues and found nothing similar.

Motivation

Currently, Fluss Flink connector supports table-level watermark via WATERMARK FOR in DDL,
which is pushed down through Flink's SupportsWatermarkPushDown interface. However, there are
two common scenarios that are not well supported:

  1. Legacy tables that already have a table-level WATERMARK definition but users want to
    disable it at query time without altering the table schema.
  2. Ad-hoc watermark override where users want to specify a different watermark column or
    delay at query time via SQL hints, without modifying the table definition.

Solution

No response

Anything else?

No response

Willingness to contribute

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels
    No fields configured for Feature.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions