You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/11/10 21:20:12 UTC
flink git commit: [hotfix] Fix ExecutionVertexDeploymentTest
compilation
Repository: flink
Updated Branches:
refs/heads/release-1.1 0bd8e0279 -> 3df5f6c00
[hotfix] Fix ExecutionVertexDeploymentTest compilation
Fixes a compilation error introduced after rebasing the previous commits.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3df5f6c0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3df5f6c0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3df5f6c0
Branch: refs/heads/release-1.1
Commit: 3df5f6c00f086d20eb077c05db22446f013adb32
Parents: 0bd8e02
Author: Ufuk Celebi <uc...@apache.org>
Authored: Thu Nov 10 22:19:39 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Thu Nov 10 22:19:40 2016 +0100
----------------------------------------------------------------------
.../runtime/executiongraph/ExecutionVertexDeploymentTest.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3df5f6c0/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexDeploymentTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexDeploymentTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexDeploymentTest.java
index b3e6b63..cec257a 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexDeploymentTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexDeploymentTest.java
@@ -34,7 +34,7 @@ import org.apache.flink.runtime.testingUtils.TestingUtils;
import org.junit.Test;
import scala.concurrent.duration.FiniteDuration;
-import java.util.List;
+import java.util.Collection;
import java.util.concurrent.TimeUnit;
import static org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils.ERROR_MESSAGE;
@@ -370,13 +370,12 @@ public class ExecutionVertexDeploymentTest {
TaskDeploymentDescriptor tdd = vertex.createDeploymentDescriptor(new ExecutionAttemptID(), slot, null, null, 1);
- List<ResultPartitionDeploymentDescriptor> producedPartitions = tdd.getProducedPartitions();
+ Collection<ResultPartitionDeploymentDescriptor> producedPartitions = tdd.getProducedPartitions();
assertEquals(1, producedPartitions.size());
- ResultPartitionDeploymentDescriptor desc = producedPartitions.get(0);
+ ResultPartitionDeploymentDescriptor desc = producedPartitions.iterator().next();
assertEquals(mode.allowLazyDeployment(), desc.sendScheduleOrUpdateConsumersMessage());
}
}
-
}