mysql cdc增量数据同步到starrocks flink命令行报错

~/app/flink-1.13.3/bin/flink run -p 2 -c com.starrocks.CDCJob -d ~/simon/cdc-sync-job-1.0.1-jar-with-dependencies.jar
–source.host cs01
–source.port 3306
–source.db simon
–source.table simon.^t_report_((?!agg).)*$
–source.user root
–source.password ‘’
–source.jobname mysqlsource
–source.parallelism 1
–sink.jdbcUrl jdbc:mysql://cs01:9013
–sink.loadUrl cs01:9011
–sink.user root
–sink.password ‘’
–sink.buffer-flush.interval-ms 15000
–sink.jobname starrocks
–sink.parallelism 1
–startup.mode ‘latest-offset’

执行以上命令,注意表参数 --source.table simon.^t_report_((?!agg).)*$ \ 这个参数配置的是一个正则表达式,执行后报以下错误

./cdc-run.sh: line 7: syntax error near unexpected token (' ./cdc-run.sh: line 7: –source.table demo.^t_report_((?!agg).)*$ ’

这个应该不是mysql cdc 的问题,你命令行的表的正则表达式需要转义

1赞