[hudi] branch master updated: [MINOR] Fixing close for HoodieCatalog's test (#5531)

[forwardxu]

This is an automated email from the ASF dual-hosted git repository.

forwardxu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 4c70840275 [MINOR] Fixing close for HoodieCatalog's test (#5531)
4c70840275 is described below

commit 4c708402758545c5097579d1a92e8d710ef1f61d
Author: ForwardXu <forwardxu...@gmail.com>
AuthorDate: Mon May 9 15:17:24 2022 +0800

    [MINOR] Fixing close for HoodieCatalog's test (#5531)
    
    * [MINOR] Fixing close for HoodieCatalog's test
---
 .../java/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 3930e763fb..8e23ef9d63 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();