[incubator-inlong] branch master updated: [INLONG-688] change additionstr to additionAtr in agent (#522)

[gosonzhang]

This is an automated email from the ASF dual-hosted git repository.

gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 806184a  [INLONG-688] change additionstr to additionAtr in agent (#522)
806184a is described below

commit 806184a9673c344212e4c573baaa3721e795213e
Author: ziruipeng <zpen...@connect.ust.hk>
AuthorDate: Fri Jul 9 09:45:02 2021 +0800

    [INLONG-688] change additionstr to additionAtr in agent (#522)
    
    Co-authored-by: stingpeng <stingp...@tencent.com>
---
 .../apache/inlong/agent/plugin/fetcher/ManagerResultFormatter.java  | 6 +++---
 .../org/apache/inlong/agent/plugin/fetcher/dtos/DataConfig.java     | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerResultFormatter.java
 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerResultFormatter.java
index b3c3907..fc64c24 100755
--- 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerResultFormatter.java
+++ 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerResultFormatter.java
@@ -52,7 +52,7 @@ public class ManagerResultFormatter {
     public static final String DEFAULT_TRIGGER = 
"org.apache.inlong.agent.plugin.trigger.DirectoryTrigger";
     public static final String DEFAULT_CHANNEL = 
"org.apache.inlong.agent.plugin.channel.MemoryChannel";
     public static final String TDM_JOB = "TDM_JOB";
-    public static final String DEFAULT_BUS_SINK = 
"org.apache.inlong.agent.plugin.sinks.TdBusSink";
+    public static final String DEFAULT_BUS_SINK = 
"org.apache.inlong.agent.plugin.sinks.ProxySink";
     public static final String DEFAULT_SOURCE = 
"org.apache.inlong.agent.plugin.sources.TextFileSource";
 
     /**
@@ -115,8 +115,8 @@ public class ManagerResultFormatter {
         job.setId(dataConfigs.getTaskId());
         job.setOp(dataConfigs.getOp());
         job.setDeliveryTime(dataConfigs.getDeliveryTime());
-        if (!dataConfigs.getAddtictiveAttr().isEmpty()) {
-            job.setAddictiveString(dataConfigs.getAddtictiveAttr());
+        if (!dataConfigs.getAdditionalAttr().isEmpty()) {
+            job.setAddictiveString(dataConfigs.getAdditionalAttr());
         }
         return job;
     }
diff --git 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/dtos/DataConfig.java
 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/dtos/DataConfig.java
index d542ffd..e367489 100644
--- 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/dtos/DataConfig.java
+++ 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/dtos/DataConfig.java
@@ -22,7 +22,7 @@ import lombok.Data;
 
 @Data
 public class DataConfig {
-    private String addtictiveAttr;
+    private String additionalAttr;
     private String businessIdentifier;
     private String dataName;
     private String dataStreamIdentifier;