111

Author: swuferhong

fluss-client/src/test/java/com/alibaba/fluss/client/table/FlussFailServerTableITCase.java

@@ -16,8 +16,6 @@
 
 package com.alibaba.fluss.client.table;
 
-import com.alibaba.fluss.client.Connection;
-import com.alibaba.fluss.client.admin.Admin;
 import com.alibaba.fluss.client.admin.ClientToServerITCaseBase;
 import com.alibaba.fluss.client.scanner.ScanRecord;
 import com.alibaba.fluss.client.scanner.log.LogScan;
@@ -29,7 +27,6 @@
 import com.alibaba.fluss.row.InternalRow;
 import com.alibaba.fluss.row.indexed.IndexedRow;
 
-import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
@@ -48,8 +45,6 @@
 class FlussFailServerTableITCase extends ClientToServerITCaseBase {
 
     private static final int SERVER = 0;
-    private Connection conn;
-    protected Admin admin;
 
     @BeforeEach
     void beforeEach() throws Exception {
@@ -60,19 +55,6 @@ void beforeEach() throws Exception {
         super.setup();
     }
 
-    @AfterEach
-    protected void teardown() throws Exception {
-        if (admin != null) {
-            admin.close();
-            admin = null;
-        }
-
-        if (conn != null) {
-            conn.close();
-            conn = null;
-        }
-    }
-
     @Test
     void testAppend() throws Exception {
         TablePath tablePath = TablePath.of("test_db_1", "test_fail_append_table_1");