背景
使用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又能成功),请问下各位大神,有没有遇到并解决这个问题的?