This is an automated email from the ASF dual-hosted git repository.
abhishek 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 d63eff3b1b Reduce contention in HttpRemoteTaskRunner.getKnownTasks()
(#14541)
d63eff3b1b is described below
commit d63eff3b1b6b15fac1bb278a784ce6c391a52ce2
Author: Kashif Faraz <[email protected]>
AuthorDate: Fri Jul 7 13:43:59 2023 +0530
Reduce contention in HttpRemoteTaskRunner.getKnownTasks() (#14541)
---
.../apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
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 7d0d210736..935f2bc61c 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
@@ -1431,11 +1431,10 @@ public class HttpRemoteTaskRunner implements
WorkerTaskRunner, TaskLogStreamer
}
@Override
+ @SuppressWarnings("GuardedBy") // Read on tasks is safe
public Collection<? extends TaskRunnerWorkItem> getKnownTasks()
{
- synchronized (statusLock) {
- return ImmutableList.copyOf(tasks.values());
- }
+ return ImmutableList.copyOf(tasks.values());
}
@SuppressWarnings("GuardedBy") // Read on tasks is safe
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
