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 2014/07/31 11:57:36 UTC
git commit: Add type parameters in OutboundConnectionQueueTest
Repository: incubator-flink
Updated Branches:
refs/heads/master a45c14b6d -> ccd495068
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/master
Commit: ccd4950689924115657ed5a764866dc63c615470
Parents: a45c14b
Author: uce <u....@fu-berlin.de>
Authored: Thu Jul 31 11:47:41 2014 +0200
Committer: uce <u....@fu-berlin.de>
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