Repository: flink Updated Branches: refs/heads/master e99949a5c -> b13db273c
[hotfix] remove Guava dependency from flink-mesos Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b13db273 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b13db273 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b13db273 Branch: refs/heads/master Commit: b13db273c200efe12f03b2e1328fce595303223d Parents: e99949a Author: Maximilian Michels <[email protected]> Authored: Tue Aug 30 12:03:07 2016 +0200 Committer: Maximilian Michels <[email protected]> Committed: Tue Aug 30 12:04:42 2016 +0200 ---------------------------------------------------------------------- .../clusterframework/store/StandaloneMesosWorkerStore.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b13db273/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java ---------------------------------------------------------------------- diff --git a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java index 55e7e28..c6ccbee 100644 --- a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java +++ b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java @@ -18,10 +18,10 @@ package org.apache.flink.mesos.runtime.clusterframework.store; -import com.google.common.collect.ImmutableList; import org.apache.mesos.Protos; import scala.Option; +import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; @@ -62,7 +62,9 @@ public class StandaloneMesosWorkerStore implements MesosWorkerStore { @Override public List<Worker> recoverWorkers() throws Exception { - return ImmutableList.copyOf(storedWorkers.values()); + List<Worker> workers = new ArrayList<>(storedWorkers.size()); + workers.addAll(storedWorkers.values()); + return workers; } @Override
