Skip to content

Commit 2d37dcd

Browse files
committed
Add warn
1 parent 67880f1 commit 2d37dcd

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

server/src/handlers/livetail.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,10 @@ impl FlightService for FlightServiceImpl {
119119
let adapter_schema = schema.clone();
120120
let rx = rx.map(move |x| match x {
121121
Message::Record(t) => Ok(utils::arrow::adapt_batch(&adapter_schema, &t)),
122-
Message::Skipped(_) => Ok(RecordBatch::new_empty(adapter_schema.clone())),
122+
Message::Skipped(_) => {
123+
log::warn!("livetail channel capacity is full.");
124+
Ok(RecordBatch::new_empty(adapter_schema.clone()))
125+
}
123126
});
124127

125128
let rb_stream = FlightDataEncoderBuilder::new()

0 commit comments

Comments
 (0)