[clickhouse] sink 不支持 物理删除操作，mysql实时同步clickhouse时delete报错

[zjinwei12]

mysql实时同步clickhouse时delete报错，显示 clickhouse不支持delete.
报错信息：

DirtyDataEntry[jobId='78a73601134bd9356ff37ab2282ee7f9', jobName='insert-into_default_catalog.default_database.test', operatorName='Sink: test', dirtyContent='{"rowKind":"DELETE","arity":3}', errorMessage='com.dtstack.chunjun.throwable.WriteRecordException: 
JdbcOutputFormat [insert-into_default_catalog.default_database.test] writeRecord error: when converting field[0] in Row(-D(6,7777,女))

希望直接在程序上去重一下 optimize TABLE table_name FINAL，数据库只保留最新的一条数据

[baisui1981]

思路：

这个我看cc上是有这个功能的，他们应该是先去查看mysql的binlog日志把mysql的操作在clickhouse复现一遍，然后通过程序判断是否执行成功了，执行成功了判断clickhouse有数据了再执行去重语句。这个optimize可以手动开启，默认是0就不执行。改成1或者其他就开启这个功能

[baisui1981]

clickhouse 删除语法

alter table test.order  delete where id=6;

[baisui1981]

chunjun 目前针对clickhouse 没有支持 https://github.com/DTStack/chunjun/blob/21b75630b3a4fbd45a165490d99e079441d799e0/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/dialect/ClickhouseDialect.java#L67

[baisui1981]

DTStack/chunjun#1606