This is an automated email from the ASF dual-hosted git repository.
lakshsingla 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 973fbaf962f Adding addition logging for taskIdReady in MSQ for
debugging lock races. (#14998)
973fbaf962f is described below
commit 973fbaf962fbf5d442c511d39ee077b4d2ff5053
Author: Karan Kumar <[email protected]>
AuthorDate: Mon Sep 18 01:41:58 2023 +0530
Adding addition logging for taskIdReady in MSQ for debugging lock races.
(#14998)
---
.../main/java/org/apache/druid/msq/indexing/MSQControllerTask.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQControllerTask.java
b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQControllerTask.java
index 5a7c0abbfda..43967e7d748 100644
---
a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQControllerTask.java
+++
b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQControllerTask.java
@@ -43,6 +43,7 @@ import org.apache.druid.indexing.common.task.AbstractTask;
import org.apache.druid.indexing.common.task.Tasks;
import org.apache.druid.java.util.common.ISE;
import org.apache.druid.java.util.common.StringUtils;
+import org.apache.druid.java.util.common.logger.Logger;
import org.apache.druid.msq.exec.Controller;
import org.apache.druid.msq.exec.ControllerContext;
import org.apache.druid.msq.exec.ControllerImpl;
@@ -69,6 +70,7 @@ public class MSQControllerTask extends AbstractTask
implements ClientTaskQuery
{
public static final String TYPE = "query_controller";
public static final String DUMMY_DATASOURCE_FOR_SELECT = "__query_select";
+ private static final Logger log = new Logger(MSQControllerTask.class);
private final MSQSpec querySpec;
@@ -204,7 +206,7 @@ public class MSQControllerTask extends AbstractTask
implements ClientTaskQuery
if (isIngestion(querySpec) && ((DataSourceMSQDestination)
querySpec.getDestination()).isReplaceTimeChunks()) {
final List<Interval> intervals =
((DataSourceMSQDestination)
querySpec.getDestination()).getReplaceTimeChunks();
-
+ log.debug("Task[%s] trying to acquire[%s] locks for intervals[%s] to
become ready", getId(), TaskLockType.EXCLUSIVE, intervals);
for (final Interval interval : intervals) {
final TaskLock taskLock =
taskActionClient.submit(new
TimeChunkLockTryAcquireAction(TaskLockType.EXCLUSIVE, interval));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
