Fix: don't set interrupt flag again after catching interrupt exception in Pulsar Client (#5643)

(cherry picked from commit b7b9926b)

Fix: don't set interrupt flag again after catching interrupt exception in Pulsar Client (#5643)
(cherry picked from commit b7b9926b)
1fae168c · Boyang Jerry Peng · xiaolong.ran · 663d24f6 · 1fae168c
隐藏空白更改
内联并排

Showing with 0 addition and 1 deletion

pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java ...a/org/apache/pulsar/client/api/PulsarClientException.java +0 -1

未找到文件。
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
@@ -232,7 +232,6 @@ public class PulsarClientException extends IOException {
        } else if (t instanceof RuntimeException) {
            throw (RuntimeException) t;
        }  else if (t instanceof InterruptedException) {
-            Thread.currentThread().interrupt();
            return new PulsarClientException(t);
        } else if (!(t instanceof ExecutionException)) {
            // Generic exception