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 2019/01/28 10:55:09 UTC
[flink] branch master updated: Enhance error message in
BucketingSinkFaultToleranceITCase
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 5c1d4e4 Enhance error message in BucketingSinkFaultToleranceITCase
5c1d4e4 is described below
commit 5c1d4e43e613ed48e8498530888e3aba69ac213a
Author: Aljoscha Krettek <al...@gmail.com>
AuthorDate: Mon Jan 28 11:51:25 2019 +0100
Enhance error message in BucketingSinkFaultToleranceITCase
We add this with the hope of finding clues about FLINK-9920.
---
.../connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.java b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.java
index 0122c18..49ef5eb 100644
--- a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.java
+++ b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.java
@@ -179,7 +179,7 @@ public class BucketingSinkFaultToleranceITCase extends StreamFaultToleranceTestB
int messageId = Integer.parseInt(matcher.group(1));
readNumbers.add(messageId);
} else {
- Assert.fail("Read line does not match expected pattern.");
+ Assert.fail("Read line does not match expected pattern. Line: " + line);
}
line = br.readLine();
}