[PIO-211] Fix pio deploy fail when using HDFS model storage

dmc-at-work · Jul 31, 2019 · b2ef983 · b2ef983
1 parent 1094de8
commit b2ef983
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/predictionio/workflow/EngineServerPluginContext.scala b/core/src/main/scala/org/apache/predictionio/workflow/EngineServerPluginContext.scala
@@ -80,8 +80,9 @@ object EngineServerPluginContext extends Logging {
 
   private def stringFromFile(filePath: String): Option[String] = {
     try {
-      val fs = FileSystem.get(new Configuration())
-      val path = new Path(new URI(filePath))
+      val uri = new URI(filePath)
+      val fs = FileSystem.get(uri, new Configuration())
+      val path = new Path(uri)
       if (fs.exists(path)) {
         Some(new String(ByteStreams.toByteArray(fs.open(path)).map(_.toChar)))
       } else {