(zeppelin) branch master updated: [ZEPPELIN-6461] Fix InterruptedException handling in recoverRunningParagraphs

[yongjae]

This is an automated email from the ASF dual-hosted git repository.

voidmatcha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git


The following commit(s) were added to refs/heads/master by this push:
     new 8595f2a148 [ZEPPELIN-6461] Fix InterruptedException handling in 
recoverRunningParagraphs
8595f2a148 is described below

commit 8595f2a148832862377b5638a7925e1850d38c2d
Author: Yerin Lee <91695537+yxi...@users.noreply.github.com>
AuthorDate: Sun Aug 9 17:04:18 2026 +0900

    [ZEPPELIN-6461] Fix InterruptedException handling in 
recoverRunningParagraphs
    
    ### What is this PR for?
     In `Notebook.recoverRunningParagraphs()`, the `InterruptedException` 
caught from `thread.join()` was handled with `e.printStackTrace()`, which 
bypasses the project's Log4j2 configuration. Additionally, the thread interrupt 
status was not restored, preventing callers from observing the interruption. 
This PR replaces `e.printStackTrace()` with SLF4J logging and adds 
`Thread.currentThread().interrupt()` to restore the interrupt status.
    
    
    ### What type of PR is it?
    Bug Fix
    
    ### Todos
    * [x] Replace `e.printStackTrace()` with `LOGGER.warn()` (SLF4J)
    * [x] Restore thread interrupt status with 
`Thread.currentThread().interrupt()`
    
    ### What is the Jira issue?
    * https://issues.apache.org/jira/browse/ZEPPELIN-6461
    
    ### How should this be tested?
      ```bash
      ./mvnw test -pl zeppelin-server -Dtest=NotebookTest -DfailIfNoTests=false
    ```
    
    ### Questions:
      - Does the license files need to update? No
      - Is there breaking changes for older versions? No
      - Does this needs documentation? No
    
    
    
    Closes #5393 from yxinot/ZEPPELIN-6461-fix-interrupted-exception-handling.
    
    Signed-off-by: YONGJAE LEE <dev.yongjae...@gmail.com>
---
 .../src/main/java/org/apache/zeppelin/notebook/Notebook.java           | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/zeppelin-server/src/main/java/org/apache/zeppelin/notebook/Notebook.java 
b/zeppelin-server/src/main/java/org/apache/zeppelin/notebook/Notebook.java
index 83f0032822..10c2abca77 100644
--- a/zeppelin-server/src/main/java/org/apache/zeppelin/notebook/Notebook.java
+++ b/zeppelin-server/src/main/java/org/apache/zeppelin/notebook/Notebook.java
@@ -207,7 +207,8 @@ public class Notebook {
     try {
       thread.join();
     } catch (InterruptedException e) {
-      e.printStackTrace();
+      LOGGER.warn("Paragraph recovery thread interrupted", e);
+      Thread.currentThread().interrupt();
     }
   }