doris同步mysql的DDL语句:增加字段失败

Viewed 61

背景

使用flinkcdc同步mysql表,并使用SchemaChange 数据流 (JsonDebeziumSchemaSerializer)同步mysql表的DDL语句。

doris版本

2.1.0

问题

当有mysql表table1 执行命令

ALTER TABLE `table1` 
ADD COLUMN `price_type` tinyint NULL DEFAULT 1 COMMENT '结算价格类型 1-配置价 2-接口价'

此时写入doris报错:

org.apache.doris.flink.sink.writer.serializer.jsondebezium.JsonDebeziumSchemaChangeImplV2 [] - Current schema change failed! You need to ensure that there is data in the table.table1

实际上table1表里面是有数据的(而且有的表执行add又能成功),请问下各位大神,有没有遇到并解决这个问题的?

2 Answers

最新版本的connector已经修复,可以升级24.0.0试试

提供下同步的脚本,能执行add成功的表是什么模型,不能成功的是什么模型?