diff --git a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java index 4be40ccd0e072..cf9f225e9d291 100644 --- a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java +++ b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java @@ -159,7 +159,9 @@ public String overwriteHoodieProperties( HoodieTableMetaClient client = HoodieCLI.getTableMetaClient(); Properties newProps = new Properties(); - newProps.load(new FileInputStream(overwriteFilePath)); + try (FileInputStream fileInputStream = new FileInputStream(overwriteFilePath)) { + newProps.load(fileInputStream); + } Map oldProps = client.getTableConfig().propsMap(); Path metaPathDir = new Path(client.getBasePath(), METAFOLDER_NAME); HoodieTableConfig.create(client.getFs(), metaPathDir, newProps); diff --git a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java index 41628dab958de..22bac81dff518 100644 --- a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java +++ b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java @@ -201,7 +201,9 @@ public String updateTableConfig( Map oldProps = client.getTableConfig().propsMap(); Properties updatedProps = new Properties(); - updatedProps.load(new FileInputStream(updatePropsFilePath)); + try (FileInputStream fileInputStream = new FileInputStream(updatePropsFilePath)) { + updatedProps.load(fileInputStream); + } Path metaPathDir = new Path(client.getBasePath(), METAFOLDER_NAME); HoodieTableConfig.update(client.getFs(), metaPathDir, updatedProps);