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 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());