mirror of https://github.com/apache/druid.git
commit
7d592939c5
2
pom.xml
2
pom.xml
|
@ -41,7 +41,7 @@
|
||||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||||
<metamx.java-util.version>0.26.6</metamx.java-util.version>
|
<metamx.java-util.version>0.26.6</metamx.java-util.version>
|
||||||
<apache.curator.version>2.6.0</apache.curator.version>
|
<apache.curator.version>2.6.0</apache.curator.version>
|
||||||
<druid.api.version>0.2.8</druid.api.version>
|
<druid.api.version>0.2.9</druid.api.version>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
|
|
@ -321,7 +321,7 @@ public class CachingClusteredClient<T> implements QueryRunner<T>
|
||||||
|
|
||||||
final QueryRunner clientQueryable = serverView.getQueryRunner(server);
|
final QueryRunner clientQueryable = serverView.getQueryRunner(server);
|
||||||
if (clientQueryable == null) {
|
if (clientQueryable == null) {
|
||||||
log.makeAlert("WTF!? server[%s] doesn't have a client Queryable?", server).emit();
|
log.error("WTF!? server[%s] doesn't have a client Queryable?", server);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -343,7 +343,7 @@ public class DirectDruidClient<T> implements QueryRunner<T>
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (IOException | InterruptedException | ExecutionException e) {
|
catch (IOException | InterruptedException | ExecutionException e) {
|
||||||
throw new RE(e, "Failure getting results from[%s]", url);
|
throw new RE(e, "Failure getting results from[%s] because of [%s]", url, e.getMessage());
|
||||||
}
|
}
|
||||||
catch (CancellationException e) {
|
catch (CancellationException e) {
|
||||||
throw new QueryInterruptedException("Query cancelled");
|
throw new QueryInterruptedException("Query cancelled");
|
||||||
|
|
Loading…
Reference in New Issue