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)