Skip to content

Commit 00df00b

Browse files
committed
fix
1 parent e0de3a2 commit 00df00b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/query/service/src/servers/http/v1/query/sized_spsc.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ impl SizedChannelBuffer {
168168
return Err(block.location.clone().unwrap());
169169
};
170170

171-
let take_rows = builder.calculate_take_rows(&data);
171+
let take_rows = builder.calculate_take_rows(data);
172172
if take_rows < data.num_rows() {
173173
builder.remain_rows = 0;
174174
builder.collector.append_block(block.slice(take_rows));

0 commit comments

Comments
 (0)