diff --git a/src/main/java/com/xiaomi/infra/pegasus/rpc/async/ReplicaSession.java b/src/main/java/com/xiaomi/infra/pegasus/rpc/async/ReplicaSession.java index 66ffaeaf..85a3e65e 100644 --- a/src/main/java/com/xiaomi/infra/pegasus/rpc/async/ReplicaSession.java +++ b/src/main/java/com/xiaomi/infra/pegasus/rpc/async/ReplicaSession.java @@ -245,6 +245,7 @@ private void markSessionConnected(Channel activeChannel) { void markSessionDisconnect() { VolatileFields cache = fields; + authSucceed = false; synchronized (pendingSend) { if (cache.state != ConnState.DISCONNECTED) { // NOTICE: