apache/fluss

Support general DELETE statement on primary key table

Open

#1,594 建立於 2025年8月26日

在 GitHub 查看
 (3 留言) (1 反應) (0 負責人)Java (570 fork)auto 404
component=kvgood first issue

倉庫指標

Star
 (1,979 star)
PR 合併指標
 (PR 指標待抓取)

描述

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!

貢獻者指南