fix:Modify the MySqlExtractNodeToOceanBaseLoadNodeTest

apache · Jul 24, 2024 · ce60e3d · ce60e3d
1 parent b19af1a
commit ce60e3d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java b/.../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 {