[FLINK-4786] [tests] Fix BarrierBufferTest validation of alignment time computation
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/14e5ecb4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/14e5ecb4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/14e5ecb4 Branch: refs/heads/master Commit: 14e5ecb46c14e8ce2885ffe4ec83cdce2a13f76c Parents: 877c267 Author: Stephan Ewen <se...@apache.org> Authored: Mon Oct 10 12:15:59 2016 +0200 Committer: Stephan Ewen <se...@apache.org> Committed: Mon Oct 10 12:17:04 2016 +0200 ---------------------------------------------------------------------- .../org/apache/flink/streaming/runtime/io/BarrierBufferTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/14e5ecb4/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java index 2cabd70..59242e8 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java @@ -442,10 +442,9 @@ public class BarrierBufferTest { check(sequence[20], buffer.getNextNonBlocked()); check(sequence[23], buffer.getNextNonBlocked()); - validateAlignmentTime(startTs, buffer); - // checkpoint 2 completed check(sequence[12], buffer.getNextNonBlocked()); + validateAlignmentTime(startTs, buffer); check(sequence[25], buffer.getNextNonBlocked()); check(sequence[27], buffer.getNextNonBlocked()); check(sequence[30], buffer.getNextNonBlocked());
