From c2d44d4d33f19c8a2a0e0e760a21ac8de391f400 Mon Sep 17 00:00:00 2001 From: Civitaspo Date: Tue, 1 Dec 2015 13:51:01 +0900 Subject: [PATCH 1/2] Fix a bug: load config files --- .../java/org/embulk/output/hdfs/HdfsFileOutputPlugin.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/embulk/output/hdfs/HdfsFileOutputPlugin.java b/src/main/java/org/embulk/output/hdfs/HdfsFileOutputPlugin.java index 432bf8d..60b3937 100644 --- a/src/main/java/org/embulk/output/hdfs/HdfsFileOutputPlugin.java +++ b/src/main/java/org/embulk/output/hdfs/HdfsFileOutputPlugin.java @@ -1,5 +1,6 @@ package org.embulk.output.hdfs; +import java.io.File; import java.io.IOException; import java.io.OutputStream; import java.util.ArrayList; @@ -176,10 +177,10 @@ private static FileSystem getFs(final PluginTask task) { Configuration configuration = new Configuration(); - for (Object configFile : task.getConfigFiles()) { - configuration.addResource(configFile.toString()); + for (String configFile : task.getConfigFiles()) { + File file = new File(configFile); + configuration.addResource(file.toURI().toURL()); } - configuration.reloadConfiguration(); for (Map.Entry entry: task.getConfig().entrySet()) { configuration.set(entry.getKey(), entry.getValue()); From 9f82a686a1ee1564b945012347d118a5487acb3d Mon Sep 17 00:00:00 2001 From: Civitaspo Date: Tue, 1 Dec 2015 13:53:33 +0900 Subject: [PATCH 2/2] Bump up v0.2.1 --- build.gradle | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/build.gradle b/build.gradle index 7be9252..e3bbec5 100644 --- a/build.gradle +++ b/build.gradle @@ -12,7 +12,7 @@ configurations { provided } -version = "0.2.0" +version = "0.2.1" sourceCompatibility = 1.7 targetCompatibility = 1.7