diff --git a/server/src/main/java/io/druid/client/DirectDruidClient.java b/server/src/main/java/io/druid/client/DirectDruidClient.java index 45f40133096..2e0e22ce48a 100644 --- a/server/src/main/java/io/druid/client/DirectDruidClient.java +++ b/server/src/main/java/io/druid/client/DirectDruidClient.java @@ -343,7 +343,7 @@ public class DirectDruidClient implements QueryRunner } } catch (IOException | InterruptedException | ExecutionException e) { - log.error(e, "Failure getting results from[%s]. Likely a timeout occurred.", url); + throw new RE(e, "Failure getting results from[%s]. Likely a timeout occurred.", url); } catch (CancellationException e) { throw new QueryInterruptedException("Query cancelled");