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!

贡献者指南