Skip to content

[flink] Allow partial updates for AGGREGATION merge engine #2887

@platinumhamburg

Description

@platinumhamburg

Search before asking

  • I searched in the issues and found nothing similar.

Description

FlinkTableSink.getSinkRuntimeProvider() rejects partial-column inserts for all merge engine tables. However, the server-side PartialAggregateRowMerger already handles partial updates correctly for AGGREGATION tables.

Willingness to contribute

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions