提交 76807ae0 编写于 作者: F Fangjin Yang

fix overloading of segments

上级 b0e1f90e
......@@ -99,9 +99,9 @@ public class ServerHolder implements Comparable<ServerHolder>
return (server.getSegment(segment.getIdentifier()) != null);
}
public boolean containsSegment(DataSegment segment)
public boolean isLoadingSegment(DataSegment segment)
{
return isServingSegment(segment) || peon.getSegmentsToLoad().contains(segment);
return peon.getSegmentsToLoad().contains(segment);
}
@Override
......
......@@ -83,7 +83,12 @@ public abstract class LoadRule implements Rule
);
break;
}
if (holder.containsSegment(segment)) {
if (holder.isServingSegment(segment)) {
assignedServers.add(holder);
continue;
}
if (holder.isLoadingSegment(segment)) {
++actualReplicants;
assignedServers.add(holder);
continue;
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册