This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new e85e91938 [test] Reduce fail number in
ChangelogWithKeyFileStoreTableITCase
e85e91938 is described below
commit e85e91938d2426c9909e2f1fd81d3aaace82e5c3
Author: JingsongLi <[email protected]>
AuthorDate: Thu Jun 29 14:08:41 2023 +0800
[test] Reduce fail number in ChangelogWithKeyFileStoreTableITCase
---
.../org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
index 05fbede0c..d1ed73f81 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
@@ -474,8 +474,6 @@ public class ChangelogWithKeyFileStoreTableITCase extends
AbstractTestBase {
private List<TableResult> testRandom(
TableEnvironment tEnv, int numProducers, boolean enableFailure,
String tableProperties)
throws Exception {
- assert LIMIT > NUM_VALUES;
-
String failingName = UUID.randomUUID().toString();
String failingPath = FailingFileIO.getFailingPath(failingName, path);
@@ -523,7 +521,7 @@ public class ChangelogWithKeyFileStoreTableITCase extends
AbstractTestBase {
List<TableResult> results = new ArrayList<>();
if (enableFailure) {
- FailingFileIO.reset(failingName, 100, 10000);
+ FailingFileIO.reset(failingName, 2, 10000);
}
for (int i = 0; i < numProducers; i++) {
// for the last `NUM_PARTS * NUM_KEYS` records, we update every
key to a specific value
