diff --git a/kylin-spark-project/kylin-spark-engine/src/main/java/org/apache/kylin/engine/spark/utils/UpdateMetadataUtil.java b/kylin-spark-project/kylin-spark-engine/src/main/java/org/apache/kylin/engine/spark/utils/UpdateMetadataUtil.java
index 11291b3698e..85f93644735 100644
--- a/kylin-spark-project/kylin-spark-engine/src/main/java/org/apache/kylin/engine/spark/utils/UpdateMetadataUtil.java
+++ b/kylin-spark-project/kylin-spark-engine/src/main/java/org/apache/kylin/engine/spark/utils/UpdateMetadataUtil.java
@@ -91,8 +91,9 @@ public static void syncLocalMetadataToRemote(KylinConfig config, NSparkExecutabl
         Path statisticsFile = new Path(statisticsDir, BatchConstants.CFG_STATISTICS_CUBOID_ESTIMATION_FILENAME);
         FileSystem fs = HadoopUtil.getWorkingFileSystem();
         if (fs.exists(statisticsFile)) {
-            FSDataInputStream is = fs.open(statisticsFile);
-            ResourceStore.getStore(config).putBigResource(resKey, is, System.currentTimeMillis());
+            try (FSDataInputStream is = fs.open(statisticsFile)) {
+                ResourceStore.getStore(config).putBigResource(resKey, is, System.currentTimeMillis());
+            }
         }
 
         CubeUpdate update = new CubeUpdate(currentInstanceCopy);