Fix file not found for path with url encoded character

Author: wForget

spark-extension-shims-spark3/src/test/scala/org/apache/spark/sql/blaze/BlazeQuerySuite.scala

@@ -0,0 +1,15 @@
+package org.apache.spark.sql.blaze
+
+import org.apache.spark.sql.Row
+
+class BlazeQuerySuite extends org.apache.spark.sql.QueryTest with BaseBlazeSQLSuite {
+
+  test("test partition path has url encoded character") {
+    withTable("t1") {
+      sql("create table t1 using parquet PARTITIONED BY (part) as select 1 as c1, 2 as c2, 'test test' as part")
+      val df = sql("select * from t1")
+      checkAnswer(df, Seq(Row(1, 2, "test test")))
+    }
+  }
+
+}

spark-extension/src/main/java/org/apache/spark/sql/blaze/JniBridge.java

@@ -17,6 +17,7 @@
 
 import java.lang.management.BufferPoolMXBean;
 import java.lang.management.ManagementFactory;
+import java.net.URI;
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 import org.apache.hadoop.fs.FileSystem;
@@ -85,7 +86,8 @@ public static boolean isDriverSide() {
     }
 
     public static FSDataInputWrapper openFileAsDataInputWrapper(FileSystem fs, String path) throws Exception {
-        return FSDataInputWrapper$.MODULE$.wrap(fs.open(new Path(path)));
+        // the path is a URI string, so we need to convert it to a URI object, ref: org.apache.spark.paths.SparkPath.toPath
+        return FSDataInputWrapper$.MODULE$.wrap(fs.open(new Path(new URI(path))));
     }
 
     public static FSDataOutputWrapper createFileAsDataOutputWrapper(FileSystem fs, String path) throws Exception {