lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fixing close for HoodieCatalog's test (#5531)

Browse Source 
* [MINOR] Fixing close for HoodieCatalog's test
This commit is contained in:
ForwardXu
2022-05-09 15:17:24 +08:00
committed by GitHub
parent 75eaa0bffe
commit 4c70840275
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java
View File

@@ -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.TableAlreadyExistException;
import org.apache.flink.table.catalog.exceptions.TableNotExistException; import org.apache.flink.table.catalog.exceptions.TableNotExistException;
import org.apache.flink.table.types.logical.LogicalTypeRoot; 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.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir; import org.junit.jupiter.api.io.TempDir;
@@ -138,6 +139,13 @@ public class TestHoodieCatalog {
catalog.open(); catalog.open();
} }
@AfterEach
void afterEach() {
if (catalog != null) {
catalog.close();
}
}
@Test @Test
public void testListDatabases() { public void testListDatabases() {
List<String> actual = catalog.listDatabases(); List<String> actual = catalog.listDatabases();