sync job has keyword error

[leizai9528]

CREATE SYNC db.test (

FROM
	db.test INTO test (
		`id`,
		`role`
	)
	
) 

FROM
BINLOG ( "type" = "canal",
"canal.server.ip" = "ip",
"canal.server.port" = "port",
"canal.destination" = "n",
"canal.username" = "nnn", "canal.password" = "pwd" );

report error:

2023-09-18 06:04:10,451 WARN (Thread-1050|138368) [StreamLoadTask.setColumnToColumnExpr():392] analyze columns' statement failed, sql=COLUMNS (id,role,delete_sign), error=Syntax error in line 1:
COLUMNS (id,role,user_id,...
^
Encountered: ROLE
Expected: ROLE is keyword, maybe ROLE

org.apache.doris.common.AnalysisException: errCode = 2, detailMessage = Syntax error
at org.apache.doris.analysis.SqlParser.unrecovered_syntax_error(SqlParser.java:2667) ~[doris-fe.jar:1.2-SNAPSHOT]
at java_cup.runtime.lr_parser.parse(lr_parser.java:616) ~[jflex-1.4.3.jar:?]
at org.apache.doris.common.util.SqlParserUtils.getFirstStmt(SqlParserUtils.java:46) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.task.StreamLoadTask.setColumnToColumnExpr(StreamLoadTask.java:387) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.task.StreamLoadTask.setOptionalFromTSLPutRequest(StreamLoadTask.java:284) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.task.StreamLoadTask.fromTStreamLoadPutRequest(StreamLoadTask.java:275) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.qe.InsertStreamTxnExecutor.beginTransaction(InsertStreamTxnExecutor.java:65) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncChannel.beginTxn(CanalSyncChannel.java:172) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncChannel.submit(CanalSyncChannel.java:270) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncDataConsumer.executeOneBatch(CanalSyncDataConsumer.java:349) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncDataConsumer.process(CanalSyncDataConsumer.java:219) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.SyncLifeCycle$2.run(SyncLifeCycle.java:48) ~[doris-fe.jar:1.2-SNAPSHOT]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_342]
2023-09-18 06:04:10,451 ERROR (Thread-1050|138368) [CanalSyncChannel.submit():281] encounter exception when submit in channel 69002, table: cs_user, batch: 71
org.apache.doris.common.AnalysisException: errCode = 2, detailMessage = Syntax error in line 1:
COLUMNS (id,role,user_id,user_nick,paren...
^
Encountered: ROLE
Expected: ROLE is keyword, maybe ROLE

at org.apache.doris.task.StreamLoadTask.setColumnToColumnExpr(StreamLoadTask.java:398) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.task.StreamLoadTask.setOptionalFromTSLPutRequest(StreamLoadTask.java:284) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.task.StreamLoadTask.fromTStreamLoadPutRequest(StreamLoadTask.java:275) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.qe.InsertStreamTxnExecutor.beginTransaction(InsertStreamTxnExecutor.java:65) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncChannel.beginTxn(CanalSyncChannel.java:172) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncChannel.submit(CanalSyncChannel.java:270) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncDataConsumer.executeOneBatch(CanalSyncDataConsumer.java:349) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.canal.CanalSyncDataConsumer.process(CanalSyncDataConsumer.java:219) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.load.sync.SyncLifeCycle$2.run(SyncLifeCycle.java:48) ~[doris-fe.jar:1.2-SNAPSHOT]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_342]

Caused by: org.apache.doris.common.AnalysisException: errCode = 2, detailMessage = Syntax error
at org.apache.doris.analysis.SqlParser.unrecovered_syntax_error(SqlParser.java:2667) ~[doris-fe.jar:1.2-SNAPSHOT]
at java_cup.runtime.lr_parser.parse(lr_parser.java:616) ~[jflex-1.4.3.jar:?]
at org.apache.doris.common.util.SqlParserUtils.getFirstStmt(SqlParserUtils.java:46) ~[doris-fe.jar:1.2-SNAPSHOT]
at org.apache.doris.task.StreamLoadTask.setColumnToColumnExpr(StreamLoadTask.java:387) ~[doris-fe.jar:1.2-SNAPSHOT]
... 9 more
2023-09-18 06:04:10,451 ERROR (Thread-1050|138368) [CanalSyncDataConsumer.executeOneBatch():364] execute event has an error, data: header {
version: 1
logfileName: "mysql-bin.000385"
logfileOffset: 9875765
serverId: 2695625202
serverenCode: "UTF-8"
executeTime: 1695017050000
sourceType: MYSQL
schemaName: "db"
tableName: "test"
eventLength: 892
eventType: UPDATE
props {
key: "rowsCount"
value: "1"
}
}
entryType: ROWDATA

[yagagagaga]

binlog load is no longer maintained, you can use Flink-Cdc to achieve the same goal.