[flink-table-store] branch master updated: [FLINK-29792] Fix unstable test FileStoreCommitTest which may stuck

[czweng]

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

czweng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new 15380474 [FLINK-29792] Fix unstable test FileStoreCommitTest which may 
stuck
15380474 is described below

commit 153804749deeb335083aeefc619b44a9276310e2
Author: tsreaper <tsreape...@gmail.com>
AuthorDate: Tue Nov 1 09:56:56 2022 +0800

    [FLINK-29792] Fix unstable test FileStoreCommitTest which may stuck
    
    This closes #341.
---
 .../flink/table/store/file/operation/FileStoreCommitTest.java       | 6 +++---
 .../apache/flink/table/store/file/operation/TestCommitThread.java   | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/FileStoreCommitTest.java
 
b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/FileStoreCommitTest.java
index 21f08f32..cb2ab9aa 100644
--- 
a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/FileStoreCommitTest.java
+++ 
b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/FileStoreCommitTest.java
@@ -95,9 +95,9 @@ public class FileStoreCommitTest {
     @CsvSource({
         "false,NONE",
         "false,INPUT",
+        "false,FULL_COMPACTION",
         "true,NONE",
         "true,INPUT",
-        "false,FULL_COMPACTION",
         "true,FULL_COMPACTION"
     })
     public void testSingleCommitUser(boolean failing, String 
changelogProducer) throws Exception {
@@ -109,9 +109,9 @@ public class FileStoreCommitTest {
     @CsvSource({
         "false,NONE",
         "false,INPUT",
+        "false,FULL_COMPACTION",
         "true,NONE",
         "true,INPUT",
-        "false,FULL_COMPACTION",
         "true,FULL_COMPACTION"
     })
     public void testManyCommitUsersNoConflict(boolean failing, String 
changelogProducer)
@@ -126,9 +126,9 @@ public class FileStoreCommitTest {
     @CsvSource({
         "false,NONE",
         "false,INPUT",
+        "false,FULL_COMPACTION",
         "true,NONE",
         "true,INPUT",
-        "false,FULL_COMPACTION",
         "true,FULL_COMPACTION"
     })
     public void testManyCommitUsersWithConflict(boolean failing, String 
changelogProducer)
diff --git 
a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/TestCommitThread.java
 
b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/TestCommitThread.java
index fbedd536..eb3317b6 100644
--- 
a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/TestCommitThread.java
+++ 
b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/TestCommitThread.java
@@ -92,7 +92,7 @@ public class TestCommitThread extends Thread {
         }
 
         this.write = safeStore.newWrite();
-        this.commit = testStore.newCommit(UUID.randomUUID().toString());
+        this.commit = 
testStore.newCommit(UUID.randomUUID().toString()).withCreateEmptyCommit(true);
     }
 
     public List<KeyValue> getResult() {