From ce60e3d439824df7e14dc64998de273bf32e9bad Mon Sep 17 00:00:00 2001
From: zyh <xxsc0529@163.com>
Date: Wed, 24 Jul 2024 14:07:06 +0800
Subject: [PATCH] fix:Modify the MySqlExtractNodeToOceanBaseLoadNodeTest

---
 .../sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java
index cbcb970ad93..7408b07df3b 100644
--- a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java
+++ b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java
@@ -80,7 +80,7 @@ private OceanBaseLoadNode buildMysqlLoadNode() {
                         new FieldRelation(new FieldInfo("phone", new IntFormatInfo()),
                                 new FieldInfo("phone", new IntFormatInfo())));
 
-        // Support delete event (sink.enable-delete='true'), requires Doris table to enable batch delete function
+        // Support delete event (sink.enable-delete='true'), requires OceanBase table to enable batch delete function
         Map<String, String> properties = new HashMap<>();
         properties.put("dirty.side-output.connector", "log");
         properties.put("dirty.ignore", "true");
@@ -108,7 +108,7 @@ private NodeRelation buildNodeRelation(List<Node> inputs, List<Node> outputs) {
     }
 
     /**
-     * Test flink sql task for extract is mysql {@link MySqlExtractNode} and load is doris {@link OceanBaseLoadNode}
+     * Test flink sql task for extract is mysql {@link MySqlExtractNode} and load is oceanbase {@link OceanBaseLoadNode}
      */
     @Test
     public void testMySqlExtractNodeToOceanBaseLoadNodeSqlParse() throws Exception {