From 5c6c1c016ca8e40c07508f83e475f6bed6804207 Mon Sep 17 00:00:00 2001
From: qingxing <qingxing@dtstack.com>
Date: Mon, 6 Jun 2022 18:17:55 +0800
Subject: [PATCH] [hotfix-#913][binlog] Fixed binlog plugin not being able to
 specify binlog file read

---
 .../chunjun/connector/binlog/inputformat/BinlogInputFormat.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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)) {