DTStack / DTStack/chunjun

[Feature][ClickHouse] Clickhouse support update sql

Open
#1,037 5 comments 0 reactions 0 assignees View on GitHub
feature-request
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

- [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar feature requirement.

### Description

当尝试在mysql数据表中更新修改某条或者删除某条数据记录的时候, 出现上述错误。

跟踪源码发现, 当实现增量实时数据同步作业时候,根据rowKind类型的值执行相关操作, 而clickhouse的 DELETE 与UPDATE_BEFORE 具体实现代码为空。 具体如下:

![image](https://user-images.githubusercontent.com/35768015/178126220-292c6175-2337-4a80-ad5f-b411d08107c9.png)

![image](https://user-images.githubusercontent.com/35768015/178126226-0603dc99-92a2-49d7-beb4-62945f8a620b.png)

![image](https://user-images.githubusercontent.com/35768015/178126232-06fa8d92-7241-4029-965f-634870db3809.png)

在此基础上,针对delete操作,添加了相关具体实现,但是对Flink相关语义以及数据原子性先关方面理解缺乏,还需要好好补充,希望大佬解惑, 指个方向, 具体如何更新操作。

### Use case

_No response_

### Related issues

_No response_

### Are you willing to submit a PR?

- [ ] Yes I am willing to submit a PR!

### Code of Conduct

- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.