Repository: incubator-flink Updated Branches: refs/heads/release-0.6 a45c14b6d -> 29ff6139a
Add type parameters in OutboundConnectionQueueTest The use of PowerMock's Whitebox without type parameters led to compile problems with Java 6. Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/ccd49506 Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/ccd49506 Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/ccd49506 Branch: refs/heads/release-0.6 Commit: ccd4950689924115657ed5a764866dc63c615470 Parents: a45c14b Author: uce <[email protected]> Authored: Thu Jul 31 11:47:41 2014 +0200 Committer: uce <[email protected]> Committed: Thu Jul 31 11:47:41 2014 +0200 ---------------------------------------------------------------------- .../runtime/io/network/netty/OutboundConnectionQueueTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/ccd49506/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/OutboundConnectionQueueTest.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/OutboundConnectionQueueTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/OutboundConnectionQueueTest.java index 1f4d98a..e2f3a14 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/OutboundConnectionQueueTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/OutboundConnectionQueueTest.java @@ -154,7 +154,7 @@ public class OutboundConnectionQueueTest { Mockito.verify(connectionManager, Mockito.times(0)).close(Mockito.any(RemoteReceiver.class)); - boolean hasRequestedClose = Whitebox.getInternalState(queue, "hasRequestedClose"); + Boolean hasRequestedClose = Whitebox.<Boolean>getInternalState(queue, "hasRequestedClose"); Assert.assertFalse("Close request while envelope in flight.", hasRequestedClose); // Change writability of channel back to writable
