You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by al...@apache.org on 2022/02/23 02:56:47 UTC
[incubator-inlong] branch master updated: [INLONG-2663][Manager] Fix inconsistent fields in manager-client module (#2665)
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 <ge...@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);