flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [2/5] flink git commit: [FLINK-4786] [tests] Fix BarrierBufferTest validation of alignment time computation
Date Mon, 10 Oct 2016 10:25:59 GMT
[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 <sewen@apache.org>
Authored: Mon Oct 10 12:15:59 2016 +0200
Committer: Stephan Ewen <sewen@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());


Mime
View raw message