update handle for join interrupted (#9)

a20b0a67 · whhe · GitHub · 38bfe41c · a20b0a67
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientStream.java ...m/oceanbase/clogproxy/client/connection/ClientStream.java +2 -1

未找到文件。
--- 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();
            }
        }
    }