Skip to content

Commit

Permalink
[improve](load) don't limit add_segment running count in load stream
Browse files Browse the repository at this point in the history
  • Loading branch information
kaijchen committed Dec 29, 2023
1 parent 03ece43 commit bc6a6ae
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions be/src/runtime/load_stream.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -193,9 +193,6 @@ Status TabletStream::add_segment(const PStreamHeader& header, butil::IOBuf* data
}
};
auto& flush_token = _flush_tokens[new_segid % _flush_tokens.size()];
while (flush_token->num_tasks() >= config::load_stream_flush_token_max_tasks) {
bthread_usleep(10 * 1000); // 10ms
}
return flush_token->submit_func(add_segment_func);
}

Expand Down

0 comments on commit bc6a6ae

Please sign in to comment.