We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
mysql实时同步clickhouse时delete报错,显示 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,数据库只保留最新的一条数据
optimize TABLE table_name FINAL
The text was updated successfully, but these errors were encountered:
思路:
这个我看cc上是有这个功能的,他们应该是先去查看mysql的binlog日志把mysql的操作在clickhouse复现一遍,然后通过程序判断是否执行成功了,执行成功了判断clickhouse有数据了再执行去重语句。这个optimize可以手动开启,默认是0就不执行。改成1或者其他就开启这个功能
Sorry, something went wrong.
clickhouse 删除语法
alter table test.order delete where id=6;
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
DTStack/chunjun#1606
No branches or pull requests
mysql实时同步clickhouse时delete报错,显示
clickhouse不支持delete
.报错信息:
希望直接在程序上去重一下
optimize TABLE table_name FINAL
,数据库只保留最新的一条数据The text was updated successfully, but these errors were encountered: