You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2015/10/19 10:34:28 UTC
flink git commit: [hotfix] Add debug output to (rarely) failing
TimestampITCase
Repository: flink
Updated Branches:
refs/heads/master d047ddb49 -> d6567a00f
[hotfix] Add debug output to (rarely) failing TimestampITCase
I'm adding this so that we have a bit more context when it fails next
time.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d6567a00
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d6567a00
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d6567a00
Branch: refs/heads/master
Commit: d6567a00fd7814dfa99b62a1d0ae3db208ae3346
Parents: d047ddb
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Mon Oct 19 10:33:23 2015 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Mon Oct 19 10:34:10 2015 +0200
----------------------------------------------------------------------
.../streaming/timestamp/TimestampITCase.java | 20 ++++++++++++++++++++
1 file changed, 20 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d6567a00/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java
index dafba9c..749e1dd 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java
@@ -147,19 +147,39 @@ public class TimestampITCase {
if (CustomOperator.finalWatermarks[i].size() == NUM_WATERMARKS + 1) {
for (int j = 0; j < NUM_WATERMARKS; j++) {
if (!CustomOperator.finalWatermarks[i].get(j).equals(new Watermark(initialTime + j))) {
+ System.err.println("All Watermarks: ");
+ for (int k = 0; k <= NUM_WATERMARKS; k++) {
+ System.err.println(CustomOperator.finalWatermarks[i].get(k));
+ }
+
Assert.fail("Wrong watermark.");
}
}
if (!CustomOperator.finalWatermarks[i].get(NUM_WATERMARKS).equals(new Watermark(Long.MAX_VALUE))) {
+ System.err.println("All Watermarks: ");
+ for (int k = 0; k <= NUM_WATERMARKS; k++) {
+ System.err.println(CustomOperator.finalWatermarks[i].get(k));
+ }
+
Assert.fail("Wrong watermark.");
}
} else {
for (int j = 0; j < NUM_WATERMARKS / 2; j++) {
if (!CustomOperator.finalWatermarks[i].get(j).equals(new Watermark(initialTime + j))) {
+ System.err.println("All Watermarks: ");
+ for (int k = 0; k <= NUM_WATERMARKS / 2; k++) {
+ System.err.println(CustomOperator.finalWatermarks[i].get(k));
+ }
+
Assert.fail("Wrong watermark.");
}
}
if (!CustomOperator.finalWatermarks[i].get(NUM_WATERMARKS / 2).equals(new Watermark(Long.MAX_VALUE))) {
+ System.err.println("All Watermarks: ");
+ for (int k = 0; k <= NUM_WATERMARKS / 2; k++) {
+ System.err.println(CustomOperator.finalWatermarks[i].get(k));
+ }
+
Assert.fail("Wrong watermark.");
}