Skip to content

Commit cea2162

Browse files
authored
Merge pull request #34356 from aljoscha/push-lvqvnwprlmvt
adapter: downgrade error logging when peek receiver goes away
2 parents 3cd5592 + de715a6 commit cea2162

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/adapter/src/coord/peek.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -989,7 +989,7 @@ impl crate::coord::Coordinator {
989989
// aesthetic reasons.
990990
let result = tx.send(response.inline_rows).await;
991991
if result.is_err() {
992-
tracing::error!("receiver went away");
992+
tracing::debug!("receiver went away");
993993
}
994994

995995
let mut current_batch = Vec::new();
@@ -1027,7 +1027,7 @@ impl crate::coord::Coordinator {
10271027
))
10281028
.await;
10291029
if result.is_err() {
1030-
tracing::error!("receiver went away");
1030+
tracing::debug!("receiver went away");
10311031
// Don't return but break so we fall out to the
10321032
// batch delete logic below.
10331033
break 'outer;
@@ -1041,7 +1041,7 @@ impl crate::coord::Coordinator {
10411041
if current_batch.len() > 0 {
10421042
let result = tx.send(RowCollection::new(current_batch, &[])).await;
10431043
if result.is_err() {
1044-
tracing::error!("receiver went away");
1044+
tracing::debug!("receiver went away");
10451045
}
10461046
}
10471047

0 commit comments

Comments
 (0)