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 3ffade3aeb..d35bcec8c0 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 @@ -267,8 +267,7 @@ public class Coordinator { private static class BackendHash implements Funnel { @Override public void funnel(Backend backend, PrimitiveSink primitiveSink) { - primitiveSink.putBytes(backend.getIp().getBytes(StandardCharsets.UTF_8)); - primitiveSink.putInt(backend.getBePort()); + primitiveSink.putLong(backend.getId()); } }