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

cleanup redundant code

This commit is contained in:
Fangjin Yang 2012-11-05 11:19:55 -08:00
parent b4e3f98f4b
commit 6b247f1599
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java
View File

@ -173,11 +173,9 @@ public class RemoteTaskRunner implements TaskRunner
@Override
public boolean apply(@Nullable WorkerWrapper input)
{
if (!input.getRunningTasks().isEmpty()) {
return false;
}
return System.currentTimeMillis() - input.getLastCompletedTaskTime().getMillis()
> config.getmaxWorkerIdleTimeMillisBeforeDeletion();
return input.getRunningTasks().isEmpty()
&& System.currentTimeMillis() - input.getLastCompletedTaskTime().getMillis()
> config.getmaxWorkerIdleTimeMillisBeforeDeletion();
}
}
)