diff --git a/docs/en/admin-manual/config/fe-config.md b/docs/en/admin-manual/config/fe-config.md index b540484e6cda2f..43ec0dd6b6cb65 100644 --- a/docs/en/admin-manual/config/fe-config.md +++ b/docs/en/admin-manual/config/fe-config.md @@ -1017,17 +1017,21 @@ IsMutable:true MasterOnly:true -Consistency checker will run from *consistency_check_start_time* to *consistency_check_end_time*. Default is from 23:00 to 04:00 +Consistency checker will run from *consistency_check_start_time* to *consistency_check_end_time*. + +If the two times are the same, no consistency check will be triggered. ### consistency_check_end_time -Default:04 +Default:23 IsMutable:true MasterOnly:true -Consistency checker will run from *consistency_check_start_time* to *consistency_check_end_time*. Default is from 23:00 to 04:00 +Consistency checker will run from *consistency_check_start_time* to *consistency_check_end_time*. + +If the two times are the same, no consistency check will be triggered. ### export_tablet_num_per_task diff --git a/docs/zh-CN/admin-manual/config/fe-config.md b/docs/zh-CN/admin-manual/config/fe-config.md index 2cb6360a95c715..c5a3a0200dc703 100644 --- a/docs/zh-CN/admin-manual/config/fe-config.md +++ b/docs/zh-CN/admin-manual/config/fe-config.md @@ -1017,11 +1017,13 @@ colocote join PlanFragment instance 的 memory_limit = exec_mem_limit / min (que 一致性检查开始时间 -一致性检查器将从 `consistency_check_start_time` 运行到 `consistency_check_end_time`。 默认为 23:00 至 04:00 +一致性检查器将从 `consistency_check_start_time` 运行到 `consistency_check_end_time`。 + +如果两个时间相同,则不会触发一致性检查。 ### `consistency_check_end_time` -默认值:04 +默认值:23 是否可以动态配置:true @@ -1029,7 +1031,9 @@ colocote join PlanFragment instance 的 memory_limit = exec_mem_limit / min (que 一致性检查结束时间 -一致性检查器将从 `consistency_check_start_time` 运行到 `consistency_check_end_time`。 默认为 23:00 至 04:00 +一致性检查器将从 `consistency_check_start_time` 运行到 `consistency_check_end_time`。 + +如果两个时间相同,则不会触发一致性检查。 ### `export_tablet_num_per_task` diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java index 4515c623c25388..a10974f42ac6f7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java @@ -856,12 +856,15 @@ public class Config extends ConfigBase { // Configurations for consistency check /** * Consistency checker will run from *consistency_check_start_time* to *consistency_check_end_time*. - * Default is from 23:00 to 04:00 + * If start time == end time, the checker will stop scheduling. + * And default is disabled. + * TODO(cmy): Disable by default because current checksum logic has some bugs. + * And it will also bring some overhead. */ @ConfField(mutable = true, masterOnly = true) public static String consistency_check_start_time = "23"; @ConfField(mutable = true, masterOnly = true) - public static String consistency_check_end_time = "4"; + public static String consistency_check_end_time = "23"; /** * Default timeout of a single consistency check task. Set long enough to fit your tablet size. */ diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index 017187e47b4bb4..431b1c25f84703 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -98,6 +98,7 @@ import com.google.common.collect.Maps; import com.google.common.collect.Multiset; import com.google.common.collect.Sets; + import org.apache.commons.collections.map.HashedMap; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; @@ -640,7 +641,8 @@ private void sendFragment() throws TException, RpcException, UserException { switch (code) { case TIMEOUT: throw new RpcException(pair.first.backend.getHost(), "send fragment timeout. backend id: " - + pair.first.backend.getId()); + + pair.first.backend.getId() + " fragment: " + + DebugUtil.printId(pair.first.rpcParams.params.fragment_instance_id)); case THRIFT_RPC_ERROR: SimpleScheduler.addToBlacklist(pair.first.backend.getId(), errMsg); throw new RpcException(pair.first.backend.getHost(), "rpc failed");