From 45222ca48a1f5f3c05558bef8428a8b1d73d421c Mon Sep 17 00:00:00 2001 From: mystarry-sky Date: Wed, 22 Jan 2025 11:18:03 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A0=A1=E9=AA=8C=E8=A1=A8=E7=BB=93=E6=9E=84?= =?UTF-8?q?=E4=B8=8D=E4=B8=80=E8=87=B4=EF=BC=8C=E5=A2=9E=E5=8A=A0error?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E8=BE=93=E5=87=BA=EF=BC=8C=E5=B9=B6=E4=B8=8A?= =?UTF-8?q?=E6=8A=A5DataKit=E5=B1=95=E7=A4=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../check/modules/check/IncrementCheckThread.java | 3 +++ .../check/modules/report/SliceCheckResultManager.java | 7 +++++++ .../datachecker/common/entry/enums/ErrorCode.java | 3 ++- 3 files changed, 12 insertions(+), 1 deletion(-) diff --git a/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/check/IncrementCheckThread.java b/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/check/IncrementCheckThread.java index e6645e6..f44f463 100644 --- a/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/check/IncrementCheckThread.java +++ b/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/check/IncrementCheckThread.java @@ -554,6 +554,9 @@ public class IncrementCheckThread extends Thread { builder.keyDeleteSet(difference.getOnlyOnRight().keySet()); } CheckDiffResult result = builder.build(); + if (!isTableStructureEquals) { + log.error("{}checked table structure failed, [{}]", ErrorCode.TABLE_STRUCTURE, tableName); + } checkResultManagerService.addResult(new CheckPartition(tableName, 0), result); } diff --git a/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/report/SliceCheckResultManager.java b/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/report/SliceCheckResultManager.java index ceb14ef..efd4040 100644 --- a/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/report/SliceCheckResultManager.java +++ b/datachecker-check/src/main/java/org/opengauss/datachecker/check/modules/report/SliceCheckResultManager.java @@ -115,10 +115,17 @@ public class SliceCheckResultManager { addTableStructureDiffResult(slice.getTable(), result); } + /** + * add table structure diff result + * + * @param table table + * @param result result + */ public void addTableStructureDiffResult(String table, CheckDiffResult result) { if (tableStructureResult.containsKey(table)) { return; } + log.error("{}checked table structure failed, [{}]", ErrorCode.TABLE_STRUCTURE, table); tableStructureResult.put(table, result); failedTableCount++; CheckFailed failed = translateCheckFailed(List.of(), List.of(result)); diff --git a/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/enums/ErrorCode.java b/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/enums/ErrorCode.java index f15ba08..bba13a5 100644 --- a/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/enums/ErrorCode.java +++ b/datachecker-common/src/main/java/org/opengauss/datachecker/common/entry/enums/ErrorCode.java @@ -48,7 +48,8 @@ public enum ErrorCode { KAFKA_LOG_CONFIG(5031, "kafka日志配置异常", "kafka log config exception"), BUILD_SLICE_POINT(5032, "生成表分割点异常", "build slice point exception"), ASYNC_EXTRACT_TABLE(5033, "同步抽取表信息异常", "async extract table info exception"), - FEEDBACK_SLICE_STATUS(5034, "反馈分片抽取状态异常", "feedback slice status exception"); + FEEDBACK_SLICE_STATUS(5034, "反馈分片抽取状态异常", "feedback slice status exception"), + TABLE_STRUCTURE(5035, "表结构不一致", "table structure not equal"); private final int code; private final String causeCn; -- Gitee