flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [blob manager] Fix flakey test.
Date Wed, 18 Feb 2015 16:44:42 GMT
Repository: flink
Updated Branches:
  refs/heads/master e6754a6da -> 42578b67a


[blob manager] Fix flakey test.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42578b67
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42578b67
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/42578b67

Branch: refs/heads/master
Commit: 42578b67a302b44978d1591c1b1b6572197d7391
Parents: e6754a6
Author: Stephan Ewen <sewen@apache.org>
Authored: Wed Feb 18 17:43:53 2015 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Wed Feb 18 17:43:53 2015 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/runtime/blob/BlobServerGetTest.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/42578b67/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerGetTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerGetTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerGetTest.java
index c564670..76383f0 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerGetTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerGetTest.java
@@ -123,7 +123,8 @@ public class BlobServerGetTest {
 			try {
 				byte[] remainder = new byte[data.length - 2*receiveBuffer.length];
 				BlobUtils.readFully(is, remainder, 0, remainder.length, null);
-				fail();
+				// we tolerate that this succeeds, as the receiver socket may have buffered
+				// everything already
 			}
 			catch (IOException e) {
 				// expected


Mime
View raw message