This is an automated email from the ASF dual-hosted git repository.
xiangfu 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 722f093ccd [feature] Reduce noise level due to slow topics (#11565)
722f093ccd is described below
commit 722f093ccd5a59f3f458c79e7158379a5b410908
Author: Alexey Pavlenko <[email protected]>
AuthorDate: Mon Sep 11 17:09:33 2023 +0300
[feature] Reduce noise level due to slow topics (#11565)
---
.../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 c1df3e5f65..002e95f1d3 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
@@ -1602,7 +1602,7 @@ public class LLRealtimeSegmentDataManager extends
RealtimeSegmentDataManager {
* Assumes there is a valid instance of {@link PartitionGroupConsumer}
*/
private void recreateStreamConsumer(String reason) {
- _segmentLogger.warn("Recreating stream consumer for topic partition {},
reason: {}", _clientId, reason);
+ _segmentLogger.info("Recreating stream consumer for topic partition {},
reason: {}", _clientId, reason);
_currentOffset = _partitionGroupConsumer.checkpoint(_currentOffset);
closePartitionGroupConsumer();
_partitionGroupConsumer =
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
