Reuse fs

civitaspo · Feb 8, 2016 · f14c622 · f14c622
1 parent e9db52f
commit f14c622
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/org/embulk/input/hdfs/HdfsFileInputPlugin.java b/src/main/java/org/embulk/input/hdfs/HdfsFileInputPlugin.java
@@ -255,7 +255,8 @@ private static FileSystem setFs(final PluginTask task)
         }
         logger.debug("Resource Files: {}", configuration);
 
-        return FileSystem.get(configuration);
+        fs = FileSystem.get(configuration);
+        return fs;
     }
 
     private String strftime(final String raw, final int rewindSeconds)