[#2353][Improvement] Remove Thread.currentThread().interrupt();

apache · Feb 13, 2025 · 3e62182 · 3e62182
1 parent e65b913
commit 3e62182
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/client/src/main/java/org/apache/uniffle/client/record/reader/RMRecordsReader.java b/client/src/main/java/org/apache/uniffle/client/record/reader/RMRecordsReader.java
@@ -262,7 +262,6 @@ public boolean next() throws IOException {
           curr = results.take();
           return curr != null;
         } catch (InterruptedException e) {
-          Thread.currentThread().interrupt();
           throw new IOException(e);
         }
       }
@@ -290,7 +289,6 @@ public boolean next() throws IOException {
           curr = results.take();
           return curr != null;
         } catch (InterruptedException e) {
-          Thread.currentThread().interrupt();
           throw new IOException(e);
         }
       }
@@ -336,7 +334,6 @@ public boolean next() throws IOException {
             return true;
           }
         } catch (InterruptedException e) {
-          Thread.currentThread().interrupt();
           throw new IOException(e);
         }
       }
@@ -388,7 +385,6 @@ public C next() {
                   curr = results.take();
                   return ret;
                 } catch (InterruptedException | IOException e) {
-                  Thread.currentThread().interrupt();
                   throw new RssException(e);
                 }
               }
@@ -612,7 +608,6 @@ public void run() {
             }
           }
         } catch (InterruptedException e) {
-          Thread.currentThread().interrupt();
           throw new RssException(e);
         }
       }
@@ -661,7 +656,6 @@ public void run() {
                   }
                   return new BufferedSegment(recordBuffer);
                 } catch (InterruptedException ex) {
-                  Thread.currentThread().interrupt();
                   throw new RssException(ex);
                 }
               });
@@ -677,7 +671,6 @@ public void run() {
       } catch (InterruptedException | IOException e) {
         error = e;
         stop = true;
-        Thread.currentThread().interrupt();
       }
     }
   }