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 85047da05 [flink][test] fix unstable testRandomCdcEventsDynamicBucket.
(#1648)
85047da05 is described below
commit 85047da0509f106fa76c9c478e2b299bddecba68
Author: liming.1018 <[email protected]>
AuthorDate: Tue Jul 25 17:34:47 2023 +0800
[flink][test] fix unstable testRandomCdcEventsDynamicBucket. (#1648)
---
.../java/org/apache/paimon/flink/sink/cdc/TestCdcSourceFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/cdc/TestCdcSourceFunction.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/cdc/TestCdcSourceFunction.java
index 507fa033d..4e03256a5 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/cdc/TestCdcSourceFunction.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/cdc/TestCdcSourceFunction.java
@@ -52,7 +52,7 @@ public class TestCdcSourceFunction extends
RichParallelSourceFunction<TestCdcEve
@Override
public void initializeState(FunctionInitializationContext context) throws
Exception {
- numRecordsPerCheckpoint = events.size() /
ThreadLocalRandom.current().nextInt(10, 20);
+ numRecordsPerCheckpoint = events.size() /
ThreadLocalRandom.current().nextInt(10, 20) + 1;
recordsThisCheckpoint = new AtomicInteger(0);
remainingEventsCount =
