This is an automated email from the ASF dual-hosted git repository.
dockerzhang 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 cee09a6579 [INLONG-10487][Manager] Fix the error of not return success
ListenerResult (#10488)
cee09a6579 is described below
commit cee09a65794a283eab9542a634ab60ec542c1ed6
Author: XiaoYou201 <[email protected]>
AuthorDate: Sat Jun 22 10:38:11 2024 +0800
[INLONG-10487][Manager] Fix the error of not return success ListenerResult
(#10488)
---
.../org/apache/inlong/manager/plugin/listener/StartupSortListener.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
index 038f35543f..001d967a56 100644
---
a/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
+++
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
@@ -95,7 +95,7 @@ public class StartupSortListener implements
SortOperateListener {
List<ListenerResult> failedStreams = listenerResults.stream()
.filter(t -> !t.isSuccess()).collect(Collectors.toList());
if (failedStreams.isEmpty()) {
- ListenerResult.success();
+ return ListenerResult.success();
}
return ListenerResult.fail(failedStreams.get(0).getRemark());
}
