[incubator-celeborn] branch main updated: [CELEBORN-924] Change log level to error in PartitionFilesSorter upon Exception

[zh...@apache.org]

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

zhouky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new f027a25db [CELEBORN-924] Change log level to error in PartitionFilesSorter upon Exception
f027a25db is described below

commit f027a25db1d59f7aa19826c02864487e1fe772f5
Author: jiaoqingbo <11...@qq.com>
AuthorDate: Mon Aug 28 16:37:09 2023 +0800

    [CELEBORN-924] Change log level to error in PartitionFilesSorter upon Exception
    
    ### What changes were proposed in this pull request?
    
    As Title
    
    ### Why are the changes needed?
    
    As Title
    
    ### Does this PR introduce _any_ user-facing change?
    
    NO
    
    ### How was this patch tested?
    
    PASS GA
    
    Closes #1847 from jiaoqingbo/CELEBORN-924.
    
    Authored-by: jiaoqingbo <11...@qq.com>
    Signed-off-by: zky.zhoukeyong <zk...@alibaba-inc.com>
---
 .../celeborn/service/deploy/worker/storage/PartitionFilesSorter.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java b/worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java
index e9bdfbf34..ed1f3f130 100644
--- a/worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java
+++ b/worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java
@@ -190,7 +190,7 @@ public class PartitionFilesSorter extends ShuffleRecoverHelper {
           sorting.add(fileId);
           shuffleSortTaskDeque.put(fileSorter);
         } catch (InterruptedException e) {
-          logger.info("Sorter scheduler thread is interrupted means worker is shutting down.");
+          logger.error("Sorter scheduler thread is interrupted means worker is shutting down.", e);
           throw new IOException(
               "Sort scheduler thread is interrupted means worker is shutting down.", e);
         } catch (IOException e) {