Merge pull request #9 from civitaspo/v0.2.1

V0.2.1

Author: civitaspo

build.gradle

@@ -12,7 +12,7 @@ configurations {
     provided
 }
 
-version = "0.2.0"
+version = "0.2.1"
 
 sourceCompatibility = 1.7
 targetCompatibility = 1.7

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<String, String> entry: task.getConfig().entrySet()) {
             configuration.set(entry.getKey(), entry.getValue());