You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2016/08/30 10:05:03 UTC
flink git commit: [hotfix] remove Guava dependency from flink-mesos
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 <mx...@apache.org>
Authored: Tue Aug 30 12:03:07 2016 +0200
Committer: Maximilian Michels <mx...@apache.org>
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