10ms

apache · Dec 20, 2023 · 664dc22 · 664dc22
1 parent 657bc5e
commit 664dc22
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/be/src/runtime/load_stream.cpp b/be/src/runtime/load_stream.cpp
@@ -139,7 +139,7 @@ Status TabletStream::append_data(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(1000 * 1000); // 1ms
+        bthread_usleep(10 * 1000 * 1000); // 10ms
     }
     return flush_token->submit_func(flush_func);
 }
@@ -177,7 +177,7 @@ 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(1000 * 1000); // 1ms
+        bthread_usleep(10 * 1000 * 1000); // 10ms
     }
     return flush_token->submit_func(add_segment_func);
 }