Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-03-03 07:49:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix according to CR

Browse Source
This commit is contained in:
fjy 2013-05-18 13:32:33 -07:00
parent 8af9598157
commit a66425fe2f
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
client/src/main/java/com/metamx/druid/client/DruidServer.java
View File

@ -139,10 +139,16 @@ public class DruidServer implements Comparable
}
dataSource.addSegment(segmentId, segment);
if (!segments.containsKey(segmentId)) {
segments.put(segmentId, segment);
currSize += segment.getSize();
DataSegment shouldNotExist = segments.get(segmentId);
if (shouldNotExist != null) {
log.warn("Asked to add data segment that already exists!? server[%s], segment[%s]", getName(), segmentId);
return this;
}
segments.put(segmentId, segment);
currSize += segment.getSize();
}
return this;
}
@ -180,10 +186,9 @@ public class DruidServer implements Comparable
}
dataSource.removePartition(segmentId);
if (segments.containsKey(segmentId)) {
segments.remove(segmentId);
currSize -= segment.getSize();
}
segments.remove(segmentId);
currSize -= segment.getSize();
if (dataSource.isEmpty()) {
dataSources.remove(dataSource.getName());