flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject [01/22] git commit: Add type parameters in OutboundConnectionQueueTest
Date Fri, 01 Aug 2014 07:29:17 GMT
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 <u.celebi@fu-berlin.de>
Authored: Thu Jul 31 11:47:41 2014 +0200
Committer: uce <u.celebi@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


Mime
View raw message