(pinot) branch master updated: Reduce warning logs when consumer thread is interrupted (#15660)

[kharekartik]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 8dc6d8d3e8 Reduce warning logs when consumer thread is interrupted 
(#15660)
8dc6d8d3e8 is described below

commit 8dc6d8d3e8e74c5a07e931ff066d16fc86b67123
Author: Kartik Khare <kharekar...@gmail.com>
AuthorDate: Tue Apr 29 12:10:12 2025 +0530

    Reduce warning logs when consumer thread is interrupted (#15660)
    
    * Reduce warning logs when consumer thread is interrupted
    
    * Reduce warning logs when consumer thread is interrupted
    
    ---------
    
    Co-authored-by: KKCorps <kar...@startee.ai>
---
 .../core/data/manager/realtime/RealtimeSegmentDataManager.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
 
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
index 3026c04e6a..d49b8484a6 100644
--- 
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
+++ 
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
@@ -437,8 +437,12 @@ public class RealtimeSegmentDataManager extends 
SegmentDataManager {
           _consecutiveErrorCount, e);
       throw e;
     } else {
-      _segmentLogger.warn("Stream transient exception when fetching messages, 
retrying (count={})",
-          _consecutiveErrorCount, e);
+      if (_shouldStop && (e instanceof InterruptedException || e.getCause() 
instanceof InterruptedException)) {
+        _segmentLogger.debug("Interrupted to stop consumption", e);
+      } else {
+        _segmentLogger.warn("Stream transient exception when fetching 
messages, retrying (count={})",
+            _consecutiveErrorCount, e);
+      }
       Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
       recreateStreamConsumer("Too many transient errors");
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org