版本信息:
StarRocks: 2.0
Flink:1.13.5
Flink CDC: flink-sql-connector-mysql-cdc-2.1.1.jar
flink-connector-starrocks-1.1.14_flink-1.13_2.12.jar
使用smt生成脚本后,执行下面命令
bin/sql-client.sh -f smt/result/flink-create.1.sql
大部分task会running,但是有些task会出现如下的报错:
Caused by: io.debezium.DebeziumException: A slave with the same server_uuid/server_id as this slave has connected to the master; the first event '' at 4, the last event read from '/sqldata/mysql3308/log-bin.000394' at 51254, the last byte read from '/sqldata/mysql3308/log-bin.000394' at 51254. Error code: 1236; SQLSTATE: HY000.
at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.wrap(MySqlStreamingChangeEventSource.java:1146)
... 5 more
Caused by: com.github.shyiko.mysql.binlog.network.ServerException: A slave with the same server_uuid/server_id as this slave has connected to the master; the first event '' at 4, the last event read from '/sqldata/mysql3308/log-bin.000394' at 51254, the last byte read from '/sqldata/mysql3308/log-bin.000394' at 51254.
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:937)
... 3 more
配置文件中并没有地方设置 server_uuid/server_id, 为啥会出现这种情况?