From bda84a36f4bd41f4c68606560bfbf7a17b52226b Mon Sep 17 00:00:00 2001 From: Himanshu Gupta Date: Wed, 17 May 2017 09:51:01 -0500 Subject: [PATCH] fix timeout check bug in DirectDruidClient --- server/src/main/java/io/druid/client/DirectDruidClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/io/druid/client/DirectDruidClient.java b/server/src/main/java/io/druid/client/DirectDruidClient.java index 5429485024f4..34d656964994 100644 --- a/server/src/main/java/io/druid/client/DirectDruidClient.java +++ b/server/src/main/java/io/druid/client/DirectDruidClient.java @@ -375,7 +375,7 @@ public int read() throws IOException private long checkQueryTimeout() { long timeLeft = timeoutAt - System.currentTimeMillis(); - if (timeLeft >= 0) { + if (timeLeft <= 0) { String msg = StringUtils.safeFormat("Query[%s] url[%s] timed out.", query.getId(), url); setupResponseReadFailure(msg, null); throw new RE(msg);