From 954303b436cd897aa35d7911cac259069507c282 Mon Sep 17 00:00:00 2001
From: wenweihuang <hww_justin@163.com>
Date: Wed, 7 Aug 2024 17:31:52 +0800
Subject: [PATCH] [INLONG-10761][Agent] Delete reader related code

---
 .../inlong/agent/plugin/sources/BinlogSource.java      | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/BinlogSource.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/BinlogSource.java
index b4bdce953d8..3bf5e16f751 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/BinlogSource.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/BinlogSource.java
@@ -19,10 +19,12 @@
 
 import org.apache.inlong.agent.conf.JobProfile;
 import org.apache.inlong.agent.plugin.Reader;
+import org.apache.inlong.agent.plugin.sources.reader.BinlogReader;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -37,7 +39,13 @@ public BinlogSource() {
 
     @Override
     public List<Reader> split(JobProfile conf) {
-        return null;
+        super.init(conf);
+        BinlogReader binlogReader = new BinlogReader();
+        binlogReader.setReadSource(conf.getInstanceId());
+        List<Reader> readerList = new ArrayList<>();
+        readerList.add(binlogReader);
+        sourceMetric.sourceSuccessCount.incrementAndGet();
+        return readerList;
     }
 
 }