请问下Flink Doris Connector 怎样能获取上游的删除标识

Viewed 9

bin/flink run
-Dexecution.checkpointing.interval=10s
-Dparallelism.default=1
-c org.apache.doris.flink.tools.cdc.CdcTools
./lib/flink-doris-connector-1.18-1.6.2.jar
sqlserver-sync-database
--job-name jobnameeer
--database martis-miip-cdr
--sqlserver-conf hostname=172.10.12.163
--sqlserver-conf port=5393
--sqlserver-conf username=sa
--sqlserver-conf password=ms2012
--sqlserver-conf database-name=lis
--sqlserver-conf schema-name=dbo
--including-tables "pa_patientinfo"
--sink-conf fenodes=172.10.100.12:8020
--sink-conf username=root
--sink-conf password=123456
--sink-conf jdbc-url=jdbc:mysql://172.10.100.12:9010
--sink-conf sink.label-prefix=label
--sink-conf sink.properties.columns=RowKind=op
--sink-conf sink.enable-delete='false'
--table-conf replication_num=1
如上,在源表数据同步至doris目标表时,如果源表执行的是delete操作,目标表在删除标志字段RowKind插入值'1',目标表不执行delete操作,只将其标识为已删除状态,上面倒数第三行这个写法不对,现在版本在配置里面能实现这个功能么

1 Answers