[MINOR] Fix convertPathWithScheme tests (apache#6251)

fengjian428 · Apr 5, 2023 · c4c1c29 · c4c1c29
1 parent 8efeec8
commit c4c1c29
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java b/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java
@@ -69,6 +69,11 @@ public void testConversionToNewSchema() {
     assertEquals(s3TablePath3, HoodieWrapperFileSystem.convertPathWithScheme(s3TablePath3, "s3"));
 
     Path hdfsTablePath = new Path("hdfs://sandbox.foo.com:8020/test.1234/table1");
-    System.out.println(HoodieWrapperFileSystem.convertPathWithScheme(hdfsTablePath, "hdfs"));
+    assertEquals(hdfsTablePath, HoodieWrapperFileSystem.convertPathWithScheme(hdfsTablePath, "hdfs"));
+
+    Path localTablePath = new Path("file:/var/table1");
+    Path localTablePathNoPrefix = new Path("/var/table1");
+    assertEquals(localTablePath, HoodieWrapperFileSystem.convertPathWithScheme(localTablePath, "file"));
+    assertEquals(localTablePath, HoodieWrapperFileSystem.convertPathWithScheme(localTablePathNoPrefix, "file"));
   }
 }