[hudi] branch master updated: [HUDI-6445] Fix flaky TestWriteCopyOnWrite tests (#9060)

[sivabalan]

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

sivabalan 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 a07549fd13b [HUDI-6445] Fix flaky TestWriteCopyOnWrite tests (#9060)
a07549fd13b is described below

commit a07549fd13bae6a74d9b82956e10520c55de3c63
Author: Sagar Sumit <sagarsumi...@gmail.com>
AuthorDate: Tue Jun 27 23:53:02 2023 +0530

    [HUDI-6445] Fix flaky TestWriteCopyOnWrite tests (#9060)
---
 .../src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java
 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java
index 291f0758553..d5d7c84ccab 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java
@@ -34,6 +34,7 @@ import org.apache.hudi.utils.TestConfigurations;
 import org.apache.hudi.utils.TestData;
 
 import org.apache.flink.configuration.Configuration;
+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;
@@ -63,6 +64,11 @@ public class TestWriteCopyOnWrite extends TestWriteBase {
     setUp(conf);
   }
 
+  @AfterEach
+  public void after() {
+    conf = null;
+  }
+
   /**
    * Override to have custom configuration.
    */
@@ -575,6 +581,7 @@ public class TestWriteCopyOnWrite extends TestWriteBase {
     
assertSame(writeClient.getConfig().getViewStorageConfig().getStorageType(), 
FileSystemViewStorageType.REMOTE_FIRST);
     assertEquals(viewStorageConfig.getRemoteViewServerPort(), 
writeClient.getConfig().getViewStorageConfig().getRemoteViewServerPort());
     assertEquals(viewStorageConfig.getRemoteTimelineClientTimeoutSecs(), 500);
+    writeClient.close();
   }
 
   // -------------------------------------------------------------------------