Limit warning logs when the WAL is full. (#4486)

quickwit-oss · Jan 31, 2024 · d6befed · d6befed
1 parent 8c4e644
commit d6befed
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/quickwit/quickwit-ingest/src/ingest_v2/ingester.rs b/quickwit/quickwit-ingest/src/ingest_v2/ingester.rs
@@ -34,7 +34,7 @@ use quickwit_cluster::Cluster;
 use quickwit_common::pubsub::{EventBroker, EventSubscriber};
 use quickwit_common::rate_limiter::{RateLimiter, RateLimiterSettings};
 use quickwit_common::tower::Pool;
-use quickwit_common::ServiceStream;
+use quickwit_common::{rate_limited_warn, ServiceStream};
 use quickwit_proto::indexing::ShardPositionsUpdate;
 use quickwit_proto::ingest::ingester::{
     AckReplicationMessage, CloseShardsRequest, CloseShardsResponse, DecommissionRequest,
@@ -484,7 +484,8 @@ impl Ingester {
                 ) {
                     Ok(_usage) => (),
                     Err(error) => {
-                        warn!(
+                        rate_limited_warn!(
+                            limit_per_min = 10,
                             "failed to persist records to ingester `{}`: {error}",
                             self.self_node_id
                         );