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 e6645e6f2b4b40db6e85559afc7bcba75df9bd1a..f44f463b2b46288b2a6af35a2fd03a9ef8c0c4ed 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 ceb14ef1b58ae9a15e01161f8d89abe9c15c2647..efd40401ef572b15b75a4da683af78eb7a13b7a5 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 f15ba085319a35bd249a3aaaf8261b1e76cf3de9..bba13a5e24e671a51554018bef672eef705524e3 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;