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 <[email protected]>
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 <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
