flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [flink-yarn-tests] Make error messages verbose for debugging
Date Mon, 13 Apr 2015 08:41:17 GMT
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 <rmetzger@apache.org>
Authored: Mon Apr 13 09:24:55 2015 +0200
Committer: Robert Metzger <rmetzger@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.


Mime
View raw message