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 60536cb132..6e63b48b05 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 @@ -227,7 +227,7 @@ protected EntryPosition findStartPosition() { checkBinlogFile(startPosition.getJournalName()); } else if (MapUtils.isNotEmpty(binlogConf.getStart())) { startPosition = new EntryPosition(); - String journalName = (String) binlogConf.getStart().get("journalName"); + String journalName = (String) binlogConf.getStart().get("journal-name"); checkBinlogFile(journalName); if (StringUtils.isNotEmpty(journalName)) {