imay closed pull request #434: Update the increased frequency of priority for
remaining tasks in Scan
URL: https://github.com/apache/incubator-doris/pull/434
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/be/src/common/config.h b/be/src/common/config.h
index 544f2de8..0a040594 100644
--- a/be/src/common/config.h
+++ b/be/src/common/config.h
@@ -379,6 +379,9 @@ namespace config {
// can perform recovering tablet
CONF_Bool(force_recovery, "false");
+
+ // the increased frequency of priority for remaining tasks in
BlockingPriorityQueue
+ CONF_Int32(priority_queue_remaining_tasks_increased_frequency, "512");
} // namespace config
} // namespace doris
diff --git a/be/src/util/blocking_priority_queue.hpp
b/be/src/util/blocking_priority_queue.hpp
index d35ea675..ac203c3d 100644
--- a/be/src/util/blocking_priority_queue.hpp
+++ b/be/src/util/blocking_priority_queue.hpp
@@ -23,6 +23,7 @@
#include <boost/thread/condition_variable.hpp>
#include <boost/thread/mutex.hpp>
+#include "common/config.h"
#include "util/stopwatch.hpp"
namespace doris {
@@ -51,7 +52,7 @@ class BlockingPriorityQueue {
if (!_queue.empty()) {
// 定期提高队列中残留的任务优先级
// 保证优先级较低的大查询不至于完全饿死
- if (_upgrade_counter > 128) {
+ if (_upgrade_counter >
config::priority_queue_remaining_tasks_increased_frequency) {
std::priority_queue<T> tmp_queue;
while (!_queue.empty()) {
T v = _queue.top();
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
