[flink] Support batch DELETE for primary-key tables

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

Currently, Fluss Flink Connector only supports DELETE pushdown when the DELETE condition contains full primary-key equality predicates, for example:

DELETE FROM orders WHERE id = 1001;

For batch DELETE statements with non-primary-key filters, partial primary-key filters, partition filters, or range conditions, Fluss does not support the row-level delete path yet. This issue aims to support batch DELETE for Fluss primary-key tables.

Users can run batch maintenance operations on Fluss tables, such as:

DELETE FROM orders WHERE dt = '2026-07-21';

DELETE FROM orders WHERE status = 'expired';

DELETE FROM orders WHERE update_time < TIMESTAMP '2026-07-01 00:00:00';

Solution

No response

Anything else?

No response

Willingness to contribute

• I'm willing to submit a PR!