From 513846eac33d15ed53ea347765a35b6c61a49249 Mon Sep 17 00:00:00 2001 From: doleyzi Date: Tue, 21 May 2024 19:03:48 +0800 Subject: [PATCH] Optimize content format --- .../inlong/audit/entity/AuditInformation.java | 4 +++ .../apache/inlong/audit/entity/FlowType.java | 4 +-- .../audit/util/AuditManagerUtilsTest.java | 26 ++++++++++--------- 3 files changed, 20 insertions(+), 14 deletions(-) diff --git a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditInformation.java b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditInformation.java index 8359b29442b..2be1662c9f8 100644 --- a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditInformation.java +++ b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditInformation.java @@ -20,6 +20,10 @@ import lombok.AllArgsConstructor; import lombok.Data; +/** + * The Audit information description currently only supports Chinese and English. + * If other languages need to be added, it can be expanded. + */ @Data @AllArgsConstructor public class AuditInformation { diff --git a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/FlowType.java b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/FlowType.java index fb72dd64429..aaf9883ae13 100644 --- a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/FlowType.java +++ b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/FlowType.java @@ -19,8 +19,8 @@ public enum FlowType { - INPUT("received", "接收"), - OUTPUT("send", "发送"); + INPUT("received", " 接收"), + OUTPUT("send", " 发送"); private final String nameInEnglish; private final String nameInChinese; diff --git a/inlong-audit/audit-sdk/src/test/java/org/apache/inlong/audit/util/AuditManagerUtilsTest.java b/inlong-audit/audit-sdk/src/test/java/org/apache/inlong/audit/util/AuditManagerUtilsTest.java index 5c9693ac964..0268826656e 100644 --- a/inlong-audit/audit-sdk/src/test/java/org/apache/inlong/audit/util/AuditManagerUtilsTest.java +++ b/inlong-audit/audit-sdk/src/test/java/org/apache/inlong/audit/util/AuditManagerUtilsTest.java @@ -44,43 +44,43 @@ public void buildAuditInformation() { AuditInformation auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(AGENT_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("Agent接收成功", auditInfo.getNameInChinese()); + assertEquals("Agent 接收成功", auditInfo.getNameInChinese()); auditType = "DataProxy"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(DATA_PROXY_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("DataProxy接收成功", auditInfo.getNameInChinese()); + assertEquals("DataProxy 接收成功", auditInfo.getNameInChinese()); auditType = "Hive"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(SORT_HIVE_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("Hive接收成功", auditInfo.getNameInChinese()); + assertEquals("Hive 接收成功", auditInfo.getNameInChinese()); auditType = "StarRocks"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(SORT_STARROCKS_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("StarRocks接收成功", auditInfo.getNameInChinese()); + assertEquals("StarRocks 接收成功", auditInfo.getNameInChinese()); // Test the scenario of dataFlow case compatibility. auditType = "agent"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(AGENT_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("Agent接收成功", auditInfo.getNameInChinese()); + assertEquals("Agent 接收成功", auditInfo.getNameInChinese()); auditType = "dataProxy"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(DATA_PROXY_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("DataProxy接收成功", auditInfo.getNameInChinese()); + assertEquals("DataProxy 接收成功", auditInfo.getNameInChinese()); auditType = "hive"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(SORT_HIVE_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("Hive接收成功", auditInfo.getNameInChinese()); + assertEquals("Hive 接收成功", auditInfo.getNameInChinese()); auditType = "STARROCKS"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); assertEquals(SORT_STARROCKS_INPUT.getValue(), auditInfo.getAuditId()); - assertEquals("StarRocks接收成功", auditInfo.getNameInChinese()); + assertEquals("StarRocks 接收成功", auditInfo.getNameInChinese()); // Test send failed audit items. auditType = "Agent"; @@ -90,28 +90,30 @@ public void buildAuditInformation() { discard = false; retry = false; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); - assertEquals("Agent发送失败", auditInfo.getNameInChinese()); + assertEquals("Agent 发送失败", auditInfo.getNameInChinese()); auditType = "DataProxy"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); - assertEquals("DataProxy发送失败", auditInfo.getNameInChinese()); + assertEquals("DataProxy 发送失败", auditInfo.getNameInChinese()); auditType = "Hive"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); - assertEquals("Hive发送失败", auditInfo.getNameInChinese()); + assertEquals("Hive 发送失败", auditInfo.getNameInChinese()); auditType = "StarRocks"; auditInfo = AuditManagerUtils.buildAuditInformation(auditType, flowType, success, isRealtime, discard, retry); - assertEquals("StarRocks发送失败", auditInfo.getNameInChinese()); + assertEquals("StarRocks 发送失败", auditInfo.getNameInChinese()); } @Test public void getAllAuditInformation() { List auditInfoList = AuditManagerUtils.getAllAuditInformation(); + System.out.println(auditInfoList); assertTrue(auditInfoList.size() > 0); auditInfoList.clear(); auditInfoList = AuditManagerUtils.getAllAuditInformation("Agent"); + assertTrue(auditInfoList.size() > 0); }