From b0f317db3256b52b8b411381524305d188b9548f Mon Sep 17 00:00:00 2001 From: zhaoliu4 Date: Fri, 28 Apr 2023 17:47:29 +0800 Subject: [PATCH] KYLIN-5539 need close FSDataInputStream --- .../apache/kylin/engine/spark/utils/UpdateMetadataUtil.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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);