morningman commented on a change in pull request #333: Add distributor which
schedule task to be fairly
URL: https://github.com/apache/incubator-doris/pull/333#discussion_r235691192
##########
File path:
fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadTaskScheduler.java
##########
@@ -44,47 +47,44 @@ protected void runOneCycle() {
try {
process();
} catch (Throwable e) {
- LOG.error("Failed to process one round of RoutineLoadTaskScheduler
with error message {}",
+ LOG.warn("Failed to process one round of RoutineLoadTaskScheduler
with error message {}",
e.getMessage(), e);
}
}
- private void process() {
+ private void process() throws LoadException {
Review comment:
The default interval of Daemon thread is 30 seconds, which means you have to
wait at least 30 seconds to schedule next batch of tasks?
Maybe you need a trigger mechanism?
----------------------------------------------------------------
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]
