You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2015/04/13 10:41:17 UTC
flink git commit: [flink-yarn-tests] Make error messages verbose for
debugging
Repository: flink
Updated Branches:
refs/heads/master 2d13c21f3 -> f89e1365f
[flink-yarn-tests] Make error messages verbose for debugging
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f89e1365
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f89e1365
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f89e1365
Branch: refs/heads/master
Commit: f89e1365ffcabcde7cef81524ad54a0ca0e2e932
Parents: 2d13c21
Author: Robert Metzger <rm...@apache.org>
Authored: Mon Apr 13 09:24:55 2015 +0200
Committer: Robert Metzger <rm...@apache.org>
Committed: Mon Apr 13 10:40:45 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/yarn/YARNSessionFIFOITCase.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/f89e1365/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
----------------------------------------------------------------------
diff --git a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
index 7b9d28b..74f658c 100644
--- a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
+++ b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
@@ -476,8 +476,8 @@ public class YARNSessionFIFOITCase extends YarnTestBase {
LOG.info("The job has finished. TaskManager output file found {}", taskmanagerOut.getAbsolutePath());
String content = FileUtils.readFileToString(taskmanagerOut);
// check for some of the wordcount outputs.
- Assert.assertTrue("Expected string '(all,2)' not found ", content.contains("(all,2)"));
- Assert.assertTrue("Expected string '(mind,1)' not found", content.contains("(mind,1)"));
+ Assert.assertTrue("Expected string '(all,2)' not found in string '"+content+"'", content.contains("(all,2)"));
+ Assert.assertTrue("Expected string '(mind,1)' not found in string'"+content+"'", content.contains("(mind,1)"));
// check if the heap size for the TaskManager was set correctly
File jobmanagerLog = YarnTestBase.findFile("..", new FilenameFilter() {
@@ -489,10 +489,10 @@ public class YARNSessionFIFOITCase extends YarnTestBase {
Assert.assertNotNull("Unable to locate JobManager log", jobmanagerLog);
content = FileUtils.readFileToString(jobmanagerLog);
// expecting 512 mb, because TM was started with 1024, we cut off 50% (NOT THE DEFAULT VALUE).
- Assert.assertTrue("Expected string 'Starting TM with command=$JAVA_HOME/bin/java -Xmx512m' not found in JobManager log",
+ Assert.assertTrue("Expected string 'Starting TM with command=$JAVA_HOME/bin/java -Xmx512m' not found in JobManager log: '"+jobmanagerLog+"'",
content.contains("Starting TM with command=$JAVA_HOME/bin/java -Xmx512m"));
Assert.assertTrue("Expected string ' (2/2) (attempt #0) to ' not found in JobManager log." +
- "This string checks that the job has been started with a parallelism of 2.",
+ "This string checks that the job has been started with a parallelism of 2. Log contents: '"+jobmanagerLog+"'",
content.contains(" (2/2) (attempt #0) to "));
// make sure the detached app is really finished.