(inlong) branch master updated: [INLONG-10345][Manager] Fix the problem of error in obtaining audit id value (#10346)

[dockerzhang]

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 8f3b920329 [INLONG-10345][Manager] Fix the problem of error in 
obtaining audit id value (#10346)
8f3b920329 is described below

commit 8f3b920329cacf99179b2cc6ead7bd6c4fe5ef5f
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Tue Jun 4 15:51:55 2024 +0800

    [INLONG-10345][Manager] Fix the problem of error in obtaining audit id 
value (#10346)
---
 .../src/main/java/org/apache/inlong/common/enums/IndicatorType.java   | 4 ++--
 .../org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/inlong-common/src/main/java/org/apache/inlong/common/enums/IndicatorType.java 
b/inlong-common/src/main/java/org/apache/inlong/common/enums/IndicatorType.java
index 0a562c9a78..d4e39b92d2 100644
--- 
a/inlong-common/src/main/java/org/apache/inlong/common/enums/IndicatorType.java
+++ 
b/inlong-common/src/main/java/org/apache/inlong/common/enums/IndicatorType.java
@@ -53,8 +53,8 @@ public enum IndicatorType {
         return UNKNOWN_TYPE;
     }
 
-    public static Boolean isFailedType(IndicatorType indicatorType) {
-        return RECEIVED_FAILED.equals(indicatorType) || 
SEND_FAILED.equals(indicatorType);
+    public static Boolean isSuccessType(IndicatorType indicatorType) {
+        return !RECEIVED_FAILED.equals(indicatorType) && 
!SEND_FAILED.equals(indicatorType);
     }
 
     public static Boolean isDiscardType(IndicatorType indicatorType) {
diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java
index 6ec2b2d370..d2ee3e8e52 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java
@@ -157,7 +157,7 @@ public class AuditServiceImpl implements AuditService {
         }
         FlowType flowType = indicatorType.getCode() % 2 == 0 ? FlowType.INPUT 
: FlowType.OUTPUT;
         auditInformation = 
AuditOperator.getInstance().buildAuditInformation(type, flowType,
-                IndicatorType.isFailedType(indicatorType),
+                IndicatorType.isSuccessType(indicatorType),
                 true,
                 IndicatorType.isDiscardType(indicatorType),
                 IndicatorType.isRetryType(indicatorType));