Repository: flink Updated Branches: refs/heads/release-0.8 ed0599fb6 -> 37cddde20
[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/37cddde2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/37cddde2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/37cddde2 Branch: refs/heads/release-0.8 Commit: 37cddde20e7343867283787abf5ee5d7a023e3c4 Parents: b5e1c5a Author: Stephan Ewen <[email protected]> Authored: Wed Feb 18 17:43:53 2015 +0100 Committer: Stephan Ewen <[email protected]> Committed: Fri Feb 20 13:25:30 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/37cddde2/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
