doris4.1.3配置MYSQL Streaming Job 报错

Question

按照官方同步教程创建MYSQL自动建表同步时报错
CREATE JOB mysql_db_sync
ON STREAMING
FROM MYSQL (
"user" = "root",
"password" = "aXRvc2Rldgo111111",
"jdbc_url" = "jdbc:mysql://10.231.229.120:3306",
"driver_url" = "mysql-connector-j-8.4.0.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"database" = "test",
"include_tables" = "students",
"offset" = "initial"
)
TO DATABASE doris_db (
"table.create.properties.replication_num" = "1" -- 单 BE 部署时设置为 1
)
报错信息：1105 - errCode = 2, detailMessage = Unknown database ''
。

daoxiwu · Answer

自己排查了半天，排除了账号权限、数据库不存在等问题。因为之前创建CATALOG并使用NSERT INTO 导入数据就是成功的，如下所示，这个方法进行数据同步就没问题。
CREATE CATALOG mysql_test_catalog PROPERTIES (
"type" = "jdbc",
"user" = "root",
"password" = "aXRvc2Rldgo111111",
"jdbc_url" = "jdbc:mysql://10.231.229.120:3306",
"driver_url" = "mysql-connector-j-8.4.0.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver"
);
CREATE DATABASE IF NOT EXISTS doris_db;

INSERT INTO doris_db.students
SELECT id, name, age FROM mysql_catalog.test.students;

doris4.1.3配置MYSQL Streaming Job 报错

1 Answers