From d080fe8c89a20962134ca119e3b6f964c1eff5e7 Mon Sep 17 00:00:00 2001 From: HHoflittlefish777 <77738092+HHoflittlefish777@users.noreply.github.com> Date: Thu, 22 Feb 2024 09:01:22 +0800 Subject: [PATCH] [log](query) add debug log for check query visible version (#31217) --- .../src/main/java/org/apache/doris/planner/OlapScanNode.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java index 9f975a6b0a..54cec43ea4 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java @@ -61,6 +61,7 @@ import org.apache.doris.common.ErrorCode; import org.apache.doris.common.ErrorReport; import org.apache.doris.common.FeConstants; import org.apache.doris.common.UserException; +import org.apache.doris.common.util.DebugUtil; import org.apache.doris.common.util.Util; import org.apache.doris.nereids.glue.translator.PlanTranslatorContext; import org.apache.doris.qe.ConnectContext; @@ -747,6 +748,10 @@ public class OlapScanNode extends ScanNode { useFixReplica = ConnectContext.get().getSessionVariable().useFixReplica; // if use_fix_replica is set to true, set skip_missing_version to false skipMissingVersion = useFixReplica == -1 && ConnectContext.get().getSessionVariable().skipMissingVersion; + if (LOG.isDebugEnabled()) { + LOG.debug("query id: {}, partition id:{} visibleVersion: {}", + DebugUtil.printId(ConnectContext.get().queryId()), partition.getId(), visibleVersion); + } } for (Tablet tablet : tablets) { long tabletId = tablet.getId();