This is an automated email from the ASF dual-hosted git repository.
jihoonson pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/master by this push:
new 63ba7f7 overlord check task whether is present before get lock (#6308)
63ba7f7 is described below
commit 63ba7f7bece496c23fe995733d0b3a5ad7e229ad
Author: dyf6372 <[email protected]>
AuthorDate: Sat Sep 29 07:57:40 2018 +0800
overlord check task whether is present before get lock (#6308)
---
.../src/main/java/org/apache/druid/indexing/overlord/TaskQueue.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskQueue.java
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskQueue.java
index b6da853..253894b 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskQueue.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskQueue.java
@@ -38,6 +38,7 @@ import
org.apache.druid.indexing.common.actions.TaskActionClientFactory;
import org.apache.druid.indexing.common.task.IndexTaskUtils;
import org.apache.druid.indexing.common.task.Task;
import org.apache.druid.indexing.overlord.config.TaskQueueConfig;
+import org.apache.druid.java.util.common.StringUtils;
import org.apache.druid.java.util.common.concurrent.ScheduledExecutors;
import org.apache.druid.java.util.common.lifecycle.LifecycleStart;
import org.apache.druid.java.util.common.lifecycle.LifecycleStop;
@@ -312,6 +313,10 @@ public class TaskQueue
*/
public boolean add(final Task task) throws EntryExistsException
{
+ if (taskStorage.getTask(task.getId()).isPresent()) {
+ throw new EntryExistsException(StringUtils.format("Task %s is already
exists", task.getId()));
+ }
+
giant.lock();
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
