Allow ScalingStats to be null

* Fixes #2378
This commit is contained in:
Charles Allen 2016-02-02 18:00:38 -08:00
parent 57a3d97837
commit a0728fa854

View File

@ -351,7 +351,7 @@ public class RemoteTaskRunner implements TaskRunner, TaskLogStreamer
@Override
public Optional<ScalingStats> getScalingStats()
{
return Optional.of(resourceManagement.getStats());
return Optional.fromNullable(resourceManagement.getStats());
}
public ZkWorker findWorkerRunningTask(String taskId)