apache/fluss

Support general DELETE statement on primary key table

Open

#1,594 opened on 2025年8月26日

GitHub で見る
 (3 comments) (1 reaction) (0 assignees)Java (570 forks)auto 404
component=kvgood first issue

Repository metrics

Stars
 (1,979 stars)
PR merge metrics
 (PR metrics pending)

説明

Search before asking

  • I searched in the issues and found nothing similar.

Motivation

See the discussion https://github.com/apache/fluss/pull/1201#discussion_r2168287356

Currently, we only support DELETE statement on primary key table with equal condition on primary key. This is very limited and we should support general DELETE statement like how we implement UPDATE statement via org.apache.fluss.flink.sink.FlinkTableSink#applyRowLevelUpdate.

Solution

No response

Anything else?

No response

Willingness to contribute

  • I'm willing to submit a PR!

コントリビューターガイド