[incubator-inlong] branch master updated: [INLONG-2663][Manager] Fix inconsistent fields in manager-client module (#2665)

[aloyszhang]

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

aloyszhang 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 8368cca  [INLONG-2663][Manager] Fix inconsistent fields in 
manager-client module (#2665)
8368cca is described below

commit 8368cca45230a119649e1acec7974a572a12d30f
Author: pacino <genzhedangd...@gmail.com>
AuthorDate: Wed Feb 23 10:56:44 2022 +0800

    [INLONG-2663][Manager] Fix inconsistent fields in manager-client module 
(#2665)
    
    * [INLONG-2663][manager] fix fields are inconsistent
    
    * [INLONG-2663][manager] fix log error
---
 .../inlong/manager/client/api/inner/InnerInlongManagerClient.java       | 2 +-
 .../org/apache/inlong/manager/workflow/definition/WorkflowTask.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
index 57006e2..2300819 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
@@ -324,7 +324,7 @@ public class InnerInlongManagerClient {
     public List<SinkListResponse> listHiveStorage(String groupId, String 
streamId) {
         final String path = HTTP_PATH + "/sink/list";
         String url = formatUrl(path);
-        url = 
String.format("%s&inlongGroupId=%s&dataStreamId=%s&storageType=HIVE", url, 
groupId, streamId);
+        url = 
String.format("%s&inlongGroupId=%s&inlongStreamId=%s&sinkType=HIVE", url, 
groupId, streamId);
         Request request = new Request.Builder().get()
                 .url(url)
                 .build();
diff --git 
a/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/WorkflowTask.java
 
b/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/WorkflowTask.java
index a763ad5..af7a925 100644
--- 
a/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/WorkflowTask.java
+++ 
b/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/WorkflowTask.java
@@ -48,7 +48,7 @@ public abstract class WorkflowTask extends NextableElement 
implements SkippableE
     public WorkflowTask addListener(TaskEventListener listener) {
         if (nameToListenerMap.containsKey(listener.name())) {
             throw new WorkflowListenerException(
-                    String.format("duplicate listener:%s for task:%s" + 
listener.name(), getName()));
+                    String.format("duplicate listener:%s for task:%s", 
listener.name(), getName()));
         }
         nameToListenerMap.put(listener.name(), listener);