diff --git a/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java b/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java index c5949ee92570..ff7ca8e14ed9 100644 --- a/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java +++ b/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java @@ -286,21 +286,20 @@ public String toString() { sb.append(":"); sb.append(address.getPort()); sb.append(" - ").append(uuid); - if (localMember()) { - sb.append(" this"); - } - // update for seatunnel, add worker and master info if (isLiteMember()) { - sb.append(" worker"); + sb.append(" [worker node]"); + } else { + sb.append(" [master node]"); } - if (instance != null && instance.node.getClusterService().getMasterAddress() != null && instance.node.getClusterService().getMasterAddress().equals(address)) { - sb.append(" master"); + sb.append(" [active master]"); + } + if (localMember()) { + sb.append(" this"); } - // update for seatunnel, add worker and master info end return sb.toString(); }