[NSE-727] Create table failed with TPCH partiton dataset (#731)

arrow-data-source/standard/src/main/scala/com/intel/oap/spark/sql/execution/datasources/v2/arrow/ArrowUtils.scala

@@ -18,6 +18,7 @@
 package com.intel.oap.spark.sql.execution.datasources.v2.arrow
 
 import java.net.URI
+import java.nio.charset.StandardCharsets
 import java.time.ZoneId
 
 import scala.collection.JavaConverters._
@@ -69,15 +70,15 @@ object ArrowUtils {
     }
   }
 
-  def makeArrowDiscovery(file: String, startOffset: Long, length: Long,
+  def makeArrowDiscovery(encodedUri: String, startOffset: Long, length: Long,
                          options: ArrowOptions): FileSystemDatasetFactory = {
 
     val format = getFormat(options)
     val allocator = SparkMemoryUtils.contextAllocator()
     val factory = new FileSystemDatasetFactory(allocator,
       SparkMemoryUtils.contextMemoryPool(),
       format,
-      rewriteUri(file),
+      rewriteUri(encodedUri),
       startOffset,
       length)
     factory
@@ -122,8 +123,9 @@ object ArrowUtils {
     }
   }
 
-  private def rewriteUri(uriStr: String): String = {
-    val uri = URI.create(uriStr)
+  private def rewriteUri(encodeUri: String): String = {
+    val decodedUri = java.net.URLDecoder.decode(encodeUri, StandardCharsets.UTF_8.name())
+    val uri = URI.create(decodedUri)
     if (uri.getScheme == "s3" || uri.getScheme == "s3a") {
       val s3Rewritten = new URI("s3", uri.getAuthority,
         uri.getPath, uri.getQuery, uri.getFragment).toString