From 4c708402758545c5097579d1a92e8d710ef1f61d Mon Sep 17 00:00:00 2001
From: ForwardXu <forwardxu315@gmail.com>
Date: Mon, 9 May 2022 15:17:24 +0800
Subject: [PATCH] [MINOR] Fixing close for HoodieCatalog's test (#5531)

* [MINOR] Fixing close for HoodieCatalog's test
---
 .../org/apache/hudi/table/catalog/TestHoodieCatalog.java  | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java
index 3930e763f..8e23ef9d6 100644
--- a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java
+++ b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java
@@ -42,6 +42,7 @@ import org.apache.flink.table.catalog.exceptions.DatabaseNotExistException;
 import org.apache.flink.table.catalog.exceptions.TableAlreadyExistException;
 import org.apache.flink.table.catalog.exceptions.TableNotExistException;
 import org.apache.flink.table.types.logical.LogicalTypeRoot;
+import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.io.TempDir;
@@ -138,6 +139,13 @@ public class TestHoodieCatalog {
     catalog.open();
   }
 
+  @AfterEach
+  void afterEach() {
+    if (catalog != null) {
+      catalog.close();
+    }
+  }
+
   @Test
   public void testListDatabases() {
     List<String> actual = catalog.listDatabases();