From 590604705b91539fc275dcfbfed7777701fbf153 Mon Sep 17 00:00:00 2001 From: mystarry-sky Date: Thu, 6 Feb 2025 11:26:50 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=86=E7=89=87=E4=B8=8A=E6=8A=A5=E5=88=B0ch?= =?UTF-8?q?eck=E7=AB=AF=E4=B8=A2=E5=A4=B1=E7=AB=AF=E7=82=B9=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=EF=BC=8C=E5=AF=BC=E8=87=B4=E8=A1=A8=E6=A0=A1=E9=AA=8C?= =?UTF-8?q?=E7=BB=93=E6=9E=9C=E5=BC=82=E5=B8=B8=E9=97=AE=E9=A2=98=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datachecker/extract/service/DataExtractServiceImpl.java | 1 - .../datachecker/extract/slice/SliceStatusFeedbackService.java | 4 +++- 2 files changed, 3 insertions(+), 2 deletions(-) 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 5c10829..3f09fd8 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 a2f6432..6d96fee 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) { -- Gitee