diff --git a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/service/DataExtractServiceImpl.java b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/service/DataExtractServiceImpl.java index 5c108295961e85b0f11d83a42df5cc51d2ceca36..3f09fd871b0d04ed85c8ebc34ec9ae31d8a51d1e 100644 --- a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/service/DataExtractServiceImpl.java +++ b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/service/DataExtractServiceImpl.java @@ -371,7 +371,6 @@ public class DataExtractServiceImpl implements DataExtractService { slice.setExistTableRows(tableMetadata.isExistTableRows()); sliceRegister.batchRegister(List.of(slice)); BeanUtils.copyProperties(slice, sliceExtend); - ThreadUtil.sleepOneSecond(); sliceProcessorContext.feedbackStatus(sliceExtend); log.info("add empty table slice task feedback status: {}->{}", tableName, sliceExtend.getStatus()); } diff --git a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/slice/SliceStatusFeedbackService.java b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/slice/SliceStatusFeedbackService.java index a2f6432586f035ec50630f64041723f4a30a2621..6d96fee4edc29e5db4cebb66f2f70d779a61aacc 100644 --- a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/slice/SliceStatusFeedbackService.java +++ b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/slice/SliceStatusFeedbackService.java @@ -16,6 +16,7 @@ package org.opengauss.datachecker.extract.slice; import org.apache.logging.log4j.Logger; +import org.opengauss.datachecker.common.config.ConfigCache; import org.opengauss.datachecker.common.entry.enums.ErrorCode; import org.opengauss.datachecker.common.entry.extract.SliceExtend; import org.opengauss.datachecker.common.util.LogUtils; @@ -89,7 +90,8 @@ public class SliceStatusFeedbackService { ThreadUtil.sleepOneSecond(); } } else { - LogUtils.debug(log, "feedback slice status of table [{}]", sliceExt); + sliceExt.setEndpoint(ConfigCache.getEndPoint()); + LogUtils.info(log, "feedback slice status of table [{}]", sliceExt); checkingClient.refreshRegisterSlice(sliceExt); } } catch (Exception ex) {