slotid equal

Signed-off-by: zombee0 <[email protected]>
zombee0 · Dec 20, 2024 · 5799707 · 5799707
1 parent baa5a2e
commit 5799707
Showing 1 changed file with 1 addition and 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
@@ -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);