dataList) throws CheckConsumerPollEmptyException {
-
-
- }
-
/**
*
* Align the bucket list data according to the statistical results of source
@@ -411,12 +396,10 @@ public class SliceCheckWorker implements Runnable {
if (MapUtils.isNotEmpty(bucketDiff)) {
bucketDiff.forEach((number, pair) -> {
if (pair.getSource() == -1) {
- sourceTuple.getBuckets()
- .add(BuilderBucketHandler.builderEmpty(number));
+ sourceTuple.getBuckets().add(BuilderBucketHandler.builderEmpty(number));
}
if (pair.getSink() == -1) {
- sinkTuple.getBuckets()
- .add(BuilderBucketHandler.builderEmpty(number));
+ sinkTuple.getBuckets().add(BuilderBucketHandler.builderEmpty(number));
}
});
}
diff --git a/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/common/CheckPointData.java b/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/common/CheckPointData.java
index 2cdfba15da0f34f4ebb46ee7e2b79c28f5e9f54f..2bbde1c93d5344ec69eb0aa9daa0eba39bcadcdf 100644
--- a/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/common/CheckPointData.java
+++ b/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/common/CheckPointData.java
@@ -17,6 +17,7 @@ package org.opengauss.datachecker.common.entry.common;
import lombok.Data;
import lombok.experimental.Accessors;
+
import org.opengauss.datachecker.common.entry.enums.Endpoint;
import java.util.List;
@@ -33,4 +34,10 @@ public class CheckPointData {
private String tableName;
private boolean isDigit;
private List