Github user prasadns14 commented on a diff in the pull request:
https://github.com/apache/drill/pull/982#discussion_r143808810
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/rm/DistributedQueryQueue.java
---
@@ -273,9 +273,8 @@ public QueueLease enqueue(QueryId queryId, double cost)
throws QueryQueueExcepti
}
if (lease == null) {
- int timeoutSecs = (int) Math.round(configSet.queueTimeout/1000.0);
- logger.warn("Queue timeout: {} after {} seconds.", queueName,
timeoutSecs);
- throw new QueueTimeoutException(queryId, queueName, timeoutSecs);
+ logger.warn("Queue timeout: {} after {} ms.", queueName,
configSet.queueTimeout);
--- End diff --
I made the change to be consistent with QueryTimeoutException which logs
the time in ms.
I made the changes as suggested in both the places.
Queue timeout: small after 60,000 ms. (60 seconds)
---
