You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by cz...@apache.org on 2022/11/01 04:25:44 UTC
[flink-table-store] branch release-0.2 updated: [FLINK-29792] Fix unstable test FileStoreCommitTest which may stuck
This is an automated email from the ASF dual-hosted git repository.
czweng pushed a commit to branch release-0.2
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
The following commit(s) were added to refs/heads/release-0.2 by this push:
new 2f97ff0c [FLINK-29792] Fix unstable test FileStoreCommitTest which may stuck
2f97ff0c is described below
commit 2f97ff0c51d189685a1b6ca81414d12487c5725a
Author: tsreaper <ts...@gmail.com>
AuthorDate: Tue Nov 1 12:25:39 2022 +0800
[FLINK-29792] Fix unstable test FileStoreCommitTest which may stuck
This closes #342.
---
.../org/apache/flink/table/store/file/operation/TestCommitThread.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 801fe612..120131be 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
@@ -86,7 +86,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() {