This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 1d258d2108 Slightly improve RTR log messages. (#12540)
1d258d2108 is described below
commit 1d258d2108f8ba40d3cb77fe2e602585b1ddfce5
Author: Gian Merlino <[email protected]>
AuthorDate: Thu May 19 07:43:55 2022 -0700
Slightly improve RTR log messages. (#12540)
1) Align "Assigning task" log messages between RTR and HRTR.
2) Remove confusing reference to "Coordinator".
3) Move "Not assigning task" message from INFO to DEBUG. It's not super
important to see this message: we mainly want to see what _does_ get
assigned.
4) Reword "Task switched from pending to running" message to better
match the structure of the "Assigning task" message from the same
method.
---
.../java/org/apache/druid/indexing/overlord/RemoteTaskRunner.java | 6 +++---
.../apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunner.java
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunner.java
index cbe213cd47..776b4556b9 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunner.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunner.java
@@ -919,10 +919,10 @@ public class RemoteTaskRunner implements
WorkerTaskRunner, TaskLogStreamer
synchronized (statusLock) {
if (!zkWorkers.containsKey(worker) || lazyWorkers.containsKey(worker)) {
// the worker might have been killed or marked as lazy
- log.info("Not assigning task to already removed worker[%s]", worker);
+ log.debug("Not assigning task to already removed worker[%s]", worker);
return false;
}
- log.info("Coordinator asking Worker[%s] to add task[%s]", worker,
task.getId());
+ log.info("Assigning task [%s] to worker [%s]", task.getId(), worker);
CuratorUtils.createIfNotExists(
cf,
@@ -949,7 +949,7 @@ public class RemoteTaskRunner implements WorkerTaskRunner,
TaskLogStreamer
RemoteTaskRunnerWorkItem newWorkItem =
workItem.withWorker(theZkWorker.getWorker(), null);
runningTasks.put(task.getId(), newWorkItem);
- log.info("Task %s switched from pending to running (on [%s])",
task.getId(), newWorkItem.getWorker().getHost());
+ log.info("Task [%s] started running on worker [%s]", task.getId(),
newWorkItem.getWorker().getHost());
TaskRunnerUtils.notifyStatusChanged(listeners, task.getId(),
TaskStatus.running(task.getId()));
// Syncing state with Zookeeper - don't assign new tasks until the task
we just assigned is actually running
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java
index fcc7352c85..1519d1824f 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java
@@ -408,7 +408,7 @@ public class HttpRemoteTaskRunner implements
WorkerTaskRunner, TaskLogStreamer
return false;
}
- log.info("Asking Worker[%s] to run task[%s]", workerHost, taskId);
+ log.info("Assigning task [%s] to worker [%s]", taskId, workerHost);
if (workerHolder.assignTask(workItem.getTask())) {
// Don't assign new tasks until the task we just assigned is actually
running
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
