diff --git a/logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientStream.java b/logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientStream.java
index 20731fe67ca73bd9ee26b6aab76f958a733fe981..4e2d53bd3912fb077da02e3c6e78d6d71eba246f 100644
--- a/logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientStream.java
+++ b/logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientStream.java
@@ -135,7 +135,8 @@ public class ClientStream {
             try {
                 thread.join();
             } catch (InterruptedException e) {
-                logger.warn("exception occurred when join LogProxy exit: ", e);
+                logger.warn("ClientStream thread is interrupted: " + e.getMessage());
+                stop();
             }
         }
     }