public boolean isRunning() {
return t != null && t.isAlive();
}
public void run() {
if(merging == true) {
<BUG>if(log.isWarnEnabled()) log.warn("merge is already in progress, terminating");
return;</BUG>
}
if(log.isDebugEnabled()) log.debug("merge task started, coordinators are " + this.coords);
try {

public boolean isRunning() {
return t != null && t.isAlive();
}
public void run() {
if(merging == true) {
if(log.isWarnEnabled()) log.warn("merge is already in progress, terminating");
return;
}
if(coords == null || coords.size() <= 1) {
if(log.isErrorEnabled()) log.error("coords == null or size <= 1");
return;
}
if(log.isDebugEnabled()) log.debug("merge task started, coordinators are " + this.coords);
try {
