[predictionio] 04/04: [PIO-211] Fix pio deploy fail when using HDFS model storage

[em...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

emergentorder pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/predictionio.git

commit b2ef98369542ddd6cd8b783574cdb9d62081a8bf
Author: Alex Merritt <le...@gmail.com>
AuthorDate: Wed Jul 31 15:06:20 2019 -0300

    [PIO-211] Fix pio deploy fail when using HDFS model storage
---
 .../org/apache/predictionio/workflow/EngineServerPluginContext.scala | 5 +++--
 1 file changed, 3 insertions(+), 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
index 011cd95..1d2eaaa 100644
--- 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 {