From f14c622c2cf99f551501536ede3fa2ecdab96c0d Mon Sep 17 00:00:00 2001
From: Civitaspo <civitaspo@gmail.com>
Date: Mon, 8 Feb 2016 14:55:57 +0900
Subject: [PATCH] Reuse fs

---
 src/main/java/org/embulk/input/hdfs/HdfsFileInputPlugin.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/embulk/input/hdfs/HdfsFileInputPlugin.java b/src/main/java/org/embulk/input/hdfs/HdfsFileInputPlugin.java
index fdd2c60..ae06614 100644
--- 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)