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 <neha.pawa...@gmail.com> 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: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org