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 <[email protected]> Authored: Thu Nov 10 22:19:39 2016 +0100 Committer: Ufuk Celebi <[email protected]> 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()); } } - }
