You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2023/04/14 09:30:25 UTC
[inlong] branch master updated: [INLONG-7847][Agent] Fix failure to create MySQL reader (#7848)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 00c1a40c4 [INLONG-7847][Agent] Fix failure to create MySQL reader (#7848)
00c1a40c4 is described below
commit 00c1a40c4f86356b23191c1ca28126af48a081f1
Author: haifxu <xh...@gmail.com>
AuthorDate: Fri Apr 14 17:30:17 2023 +0800
[INLONG-7847][Agent] Fix failure to create MySQL reader (#7848)
---
.../java/org/apache/inlong/agent/plugin/sources/BinlogSource.java | 3 ++-
.../org/apache/inlong/agent/plugin/sources/reader/BinlogReader.java | 4 ++++
2 files changed, 6 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 4bf1a7296..e6b44e283 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
@@ -39,7 +39,8 @@ public class BinlogSource extends AbstractSource {
@Override
public List<Reader> split(JobProfile conf) {
super.init(conf);
- Reader binlogReader = new BinlogReader();
+ BinlogReader binlogReader = new BinlogReader();
+ binlogReader.setReadSource(conf.getInstanceId());
List<Reader> readerList = new ArrayList<>();
readerList.add(binlogReader);
sourceMetric.sourceSuccessCount.incrementAndGet();
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/BinlogReader.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/BinlogReader.java
index fa61c0a10..24360e72f 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/BinlogReader.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/BinlogReader.java
@@ -258,6 +258,10 @@ public class BinlogReader extends AbstractReader {
return instanceId;
}
+ public void setReadSource(String instanceId) {
+ this.instanceId = instanceId;
+ }
+
@Override
public void setReadTimeout(long mill) {
}