From 5799707dff4d692ab603d3159ec9b061f2d7dcbc Mon Sep 17 00:00:00 2001 From: zombee0 Date: Fri, 20 Dec 2024 20:43:22 +0800 Subject: [PATCH] slotid equal Signed-off-by: zombee0 --- .../src/main/java/com/starrocks/qe/ExecuteExceptionHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/com/starrocks/qe/ExecuteExceptionHandler.java b/fe/fe-core/src/main/java/com/starrocks/qe/ExecuteExceptionHandler.java index 61b94c6a9162a5..0a1c622ec3f1e6 100644 --- a/fe/fe-core/src/main/java/com/starrocks/qe/ExecuteExceptionHandler.java +++ b/fe/fe-core/src/main/java/com/starrocks/qe/ExecuteExceptionHandler.java @@ -104,7 +104,7 @@ private static void tryTriggerRefreshDictAsync(GlobalDictNotMatchException e, Re } SlotId slotId = new SlotId(err.first.get()); for (ScanNode scanNode : context.execPlan.getScanNodes()) { - if (scanNode.getDesc().getSlots().stream().anyMatch(x -> x.getId() == slotId)) { + if (scanNode.getDesc().getSlots().stream().anyMatch(x -> x.getId().equals(slotId))) { String columnName = scanNode.getDesc().getSlot(slotId.asInt()).getColumn().getName(); String tableUUID = scanNode.getDesc().getTable().getUUID(); StatisticExecutor.updateDictASync(tableUUID, columnName, err.second);