diff --git a/chunjun-connectors/chunjun-connector-binlog/src/main/java/com/dtstack/chunjun/connector/binlog/inputformat/BinlogInputFormat.java b/chunjun-connectors/chunjun-connector-binlog/src/main/java/com/dtstack/chunjun/connector/binlog/inputformat/BinlogInputFormat.java index 6e63b48b05..05201ab42d 100644 --- a/chunjun-connectors/chunjun-connector-binlog/src/main/java/com/dtstack/chunjun/connector/binlog/inputformat/BinlogInputFormat.java +++ b/chunjun-connectors/chunjun-connector-binlog/src/main/java/com/dtstack/chunjun/connector/binlog/inputformat/BinlogInputFormat.java @@ -254,7 +254,7 @@ private void checkBinlogFile(String journalName) { binlogConf.getUsername(), binlogConf.getPassword()) .check(journalName)) { - throw new IllegalArgumentException("Can't find journalName: " + journalName); + throw new IllegalArgumentException("Can't find journal-name: " + journalName); } } } diff --git a/chunjun-examples/json/binlog/binlog_stream.json b/chunjun-examples/json/binlog/binlog_stream.json index fbfed2bf71..1179ea74bc 100644 --- a/chunjun-examples/json/binlog/binlog_stream.json +++ b/chunjun-examples/json/binlog/binlog_stream.json @@ -11,7 +11,7 @@ "host" : "localhost", "port" : 3306, "start" : { - "journalName": "mysql-bin.000001" + "journal-name": "mysql-bin.000001" }, "table" : [ ], "splitUpdate" : true, diff --git a/docs/connectors-en/binlog/binlog-source.md b/docs/connectors-en/binlog/binlog-source.md index a359f398d2..5feffdd937 100644 --- a/docs/connectors-en/binlog/binlog-source.md +++ b/docs/connectors-en/binlog/binlog-source.md @@ -137,10 +137,10 @@ Why does Binlog need these permissions: - **start** - Description: The starting position of the binlog file to be read - - Note: If it is empty, it will be consumed from the current position, and the priority of timestamp is higher than journalName+position + - Note: If it is empty, it will be consumed from the current position, and the priority of timestamp is higher than journal-name+position - Parameters: - timestamp: timestamp, the start point of collection is consumed from the specified timestamp; - - journalName: file name, the start point of collection is consumed from the beginning of the specified file; + - journal-name: file name, the start point of collection is consumed from the beginning of the specified file; - position: the specified position of the file, the start point of collection is consumed from the specified position of the specified file - Field type: map - Default value: none diff --git a/docs/connectors/binlog/binlog-source.md b/docs/connectors/binlog/binlog-source.md index 17ae5f009d..567f1bf077 100644 --- a/docs/connectors/binlog/binlog-source.md +++ b/docs/connectors/binlog/binlog-source.md @@ -145,7 +145,7 @@ Binlog为什么需要这些权限: - **start** - 描述:要读取的binlog文件的开始位置 - - 注意:为空,则从当前position处消费,timestamp的优先级高于 journalName+position + - 注意:为空,则从当前position处消费,timestamp的优先级高于 journal-name+position - 参数: - timestamp:时间戳,采集起点从指定的时间戳处消费; - journal-name:文件名,采集起点从指定文件的起始处消费;