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 <[email protected]> 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 {
