Merge pull request #2379 from metamx/fix2378

Allow ScalingStats to be null
This commit is contained in:
Fangjin Yang 2016-02-02 18:45:03 -08:00
commit 13ff87fd12
1 changed files with 1 additions and 1 deletions

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)