Tornado
flink classpath 如下 ``` /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/chunjun-core.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/binlog/chunjun-connector-binlog.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/cassandra/chunjun-connector-cassandra.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/clickhouse/chunjun-connector-clickhouse.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/db2/chunjun-connector-db2.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/dm/chunjun-connector-dm.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/doris/chunjun-connector-doris.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/elasticsearch7/chunjun-connector-elasticsearch7.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/emqx/chunjun-connector-emqx.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/file/chunjun-connector-file.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/filesystem/chunjun-connector-filesystem.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/ftp/chunjun-connector-ftp.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/greenplum/chunjun-connector-greenplum.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/hbase14/chunjun-connector-hbase-1.4.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/hbase2/chunjun-connector-hbase2.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/hdfs/chunjun-connector-hdfs.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/hive3/chunjun-connector-hive3.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/hive/chunjun-connector-hiv e.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/http/chunjun-connector-http.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/iceberg/chunjun-connector-iceberg.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/influxdb/chunjun-connector-influxdb.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/kafka/chunjun-connector-kafka.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/kudu/chunjun-connector-kudu.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/mongodb/chunjun-connector-mongodb.jar /data/insight_plugin1.12/flink-1.12.7/lib/chunjun-dist/connector/mysqlcdc/chunjun-connector-mysqlcdc.jar...
继续尝试了下，发现了一种情况。 ``` CREATE TABLE test1( id INT, name varchar, p_id int, updateTime timestamp, primary key(id) not enforced )WITH( 'connector'='mysql-cdc', 'hostname'='192.168.1.121', 'port'='3306', 'database-name'='dgy', 'table-name'='test1', 'username'='root', 'password'='Daxxx3' ); ``` 第一次直接执行会报如下的错误 ``` Caused...
> 你的启动命令好像是指定的json脚本模式提交，而不是sql模式，建议多参考官网例子看一下，mysqlcdc并不稳定吧 指定了 sql 模式还是一样，我看 submit.sh 也有作类型适配，sql 文件后缀会当成 sql 类型处理，可能还是其他问题~
我修改了 org.apache.flink.table.factories.FactoryUtil 这个文件，重新编译下就好了 不确定是bug还是我环境的问题，反正就先这样，给后面的人一点参考，如果有更加完美的方案，麻烦告知一下，谢谢。 
@KerYooz 可以麻烦看下我这个 issue 吗，也有类似的问题 https://github.com/DTStack/chunjun/issues/1752