Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix NPE

This commit is contained in:
fjy 2014-04-23 16:51:12 -07:00
parent 174ff66a88
commit 7f0319a8ae
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
server/src/main/java/io/druid/server/ClientInfoResource.java
View File

@ -101,7 +101,12 @@ public class ClientInfoResource
@QueryParam("interval") String interval
)
{
List<DataSegment> segments = getSegmentsForDatasources().get(dataSourceName);
final List<DataSegment> segments = getSegmentsForDatasources().get(dataSourceName);
final Set<String> dims = Sets.newHashSet();
if (segments == null || segments.isEmpty()) {
return dims;
}
Interval theInterval;
if (interval == null || interval.isEmpty()) {
@ -111,7 +116,6 @@ public class ClientInfoResource
theInterval = new Interval(interval);
}
Set<String> dims = Sets.newHashSet();
for (DataSegment segment : segments) {
if (theInterval.overlaps(segment.getInterval())) {
dims.addAll(segment.getDimensions());
@ -129,7 +133,12 @@ public class ClientInfoResource
@QueryParam("interval") String interval
)
{
List<DataSegment> segments = getSegmentsForDatasources().get(dataSourceName);
final List<DataSegment> segments = getSegmentsForDatasources().get(dataSourceName);
final Set<String> metrics = Sets.newHashSet();
if (segments == null || segments.isEmpty()) {
return metrics;
}
Interval theInterval;
if (interval == null || interval.isEmpty()) {
@ -139,7 +148,6 @@ public class ClientInfoResource
theInterval = new Interval(interval);
}
Set<String> metrics = Sets.newHashSet();
for (DataSegment segment : segments) {
if (theInterval.overlaps(segment.getInterval())) {
metrics.addAll(segment.getMetrics());