This is an automated email from the ASF dual-hosted git repository.
nehapawar 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 35cef48b Change error to warn in catchupToFinalOffset (#8005)
35cef48b is described below
commit 35cef48b8198937684a88e57baa85c01b2133ffa
Author: Neha Pawar <[email protected]>
AuthorDate: Wed Jan 12 14:37:26 2022 -0800
Change error to warn in catchupToFinalOffset (#8005)
---
.../pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
index 434a7b4..5233ff2 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
@@ -1162,7 +1162,7 @@ public class LLRealtimeSegmentDataManager extends
RealtimeSegmentDataManager {
}
if (_currentOffset.compareTo(endOffset) != 0) {
// Timeout?
- _segmentLogger.error("Could not consume up to {} (current offset {})",
endOffset, _currentOffset);
+ _segmentLogger.warn("Could not consume up to {} (current offset {})",
endOffset, _currentOffset);
return false;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
