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 2016/10/21 12:21:41 UTC
flink git commit: [FLINK-4878][tests] Log test failure cause on INFO
level
Repository: flink
Updated Branches:
refs/heads/master 58a16c100 -> 7398fdbfe
[FLINK-4878][tests] Log test failure cause on INFO level
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7398fdbf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7398fdbf
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7398fdbf
Branch: refs/heads/master
Commit: 7398fdbfe024652b4299b582c2e1559da473011d
Parents: 58a16c1
Author: Robert Metzger <rm...@apache.org>
Authored: Fri Oct 21 11:23:44 2016 +0200
Committer: Robert Metzger <rm...@apache.org>
Committed: Fri Oct 21 14:21:30 2016 +0200
----------------------------------------------------------------------
.../runtime/operators/ReduceTaskExternalITCase.java | 16 ++++++++--------
.../flink/runtime/operators/ReduceTaskTest.java | 16 ++++++++--------
2 files changed, 16 insertions(+), 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/7398fdbf/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskExternalITCase.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskExternalITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskExternalITCase.java
index babe69e..969f180 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskExternalITCase.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskExternalITCase.java
@@ -74,8 +74,8 @@ public class ReduceTaskExternalITCase extends DriverTestBase<RichGroupReduceFunc
testDriver(testTask, MockReduceStub.class);
} catch (Exception e) {
- LOG.debug("Exception while running the test task.", e);
- Assert.fail("Exception in Test.");
+ LOG.info("Exception while running the test task.", e);
+ Assert.fail("Exception in Test: " + e.getMessage());
}
Assert.assertTrue("Resultset size was "+this.outList.size()+". Expected was "+keyCnt, this.outList.size() == keyCnt);
@@ -106,8 +106,8 @@ public class ReduceTaskExternalITCase extends DriverTestBase<RichGroupReduceFunc
testDriver(testTask, MockReduceStub.class);
} catch (Exception e) {
- LOG.debug("Exception while running the test task.", e);
- Assert.fail("Exception in Test.");
+ LOG.info("Exception while running the test task.", e);
+ Assert.fail("Exception in Test: " + e.getMessage());
}
Assert.assertTrue("Resultset size was "+this.outList.size()+". Expected was "+keyCnt, this.outList.size() == keyCnt);
@@ -143,8 +143,8 @@ public class ReduceTaskExternalITCase extends DriverTestBase<RichGroupReduceFunc
testDriver(testTask, MockCombiningReduceStub.class);
} catch (Exception e) {
- LOG.debug("Exception while running the test task.", e);
- Assert.fail("Invoke method caused exception.");
+ LOG.info("Exception while running the test task.", e);
+ Assert.fail("Invoke method caused exception: " + e.getMessage());
} finally {
if (sorter != null) {
sorter.close();
@@ -189,8 +189,8 @@ public class ReduceTaskExternalITCase extends DriverTestBase<RichGroupReduceFunc
testDriver(testTask, MockCombiningReduceStub.class);
} catch (Exception e) {
- LOG.debug("Exception while running the test task.", e);
- Assert.fail("Invoke method caused exception.");
+ LOG.info("Exception while running the test task.", e);
+ Assert.fail("Invoke method caused exception: " + e.getMessage());
} finally {
if (sorter != null) {
sorter.close();
http://git-wip-us.apache.org/repos/asf/flink/blob/7398fdbf/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskTest.java
index 718b446..5b37e86 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/ReduceTaskTest.java
@@ -75,8 +75,8 @@ public class ReduceTaskTest extends DriverTestBase<RichGroupReduceFunction<Recor
testDriver(testTask, MockReduceStub.class);
} catch (Exception e) {
- LOG.debug("Exception while running the test task.", e);
- Assert.fail("Exception in Test.");
+ LOG.info("Exception while running the test task.", e);
+ Assert.fail("Exception in Test: " + e.getMessage());
}
Assert.assertTrue("Resultset size was "+this.outList.size()+". Expected was "+keyCnt, this.outList.size() == keyCnt);
@@ -103,8 +103,8 @@ public class ReduceTaskTest extends DriverTestBase<RichGroupReduceFunction<Recor
try {
testDriver(testTask, MockReduceStub.class);
} catch (Exception e) {
- LOG.debug("Exception while running the test task.", e);
- Assert.fail("Invoke method caused exception.");
+ LOG.info("Exception while running the test task.", e);
+ Assert.fail("Invoke method caused exception: " + e.getMessage());
}
Assert.assertTrue("Resultset size was "+this.outList.size()+". Expected was "+keyCnt, this.outList.size() == keyCnt);
@@ -137,8 +137,8 @@ public class ReduceTaskTest extends DriverTestBase<RichGroupReduceFunction<Recor
testDriver(testTask, MockCombiningReduceStub.class);
} catch (Exception e) {
- LOG.debug("Exception while running the test task.", e);
- Assert.fail("Invoke method caused exception.");
+ LOG.info("Exception while running the test task.", e);
+ Assert.fail("Invoke method caused exception: " + e.getMessage());
} finally {
if (sorter != null) {
sorter.close();
@@ -178,8 +178,8 @@ public class ReduceTaskTest extends DriverTestBase<RichGroupReduceFunction<Recor
} catch (ExpectedTestException eetex) {
// Good!
} catch (Exception e) {
- LOG.debug("Exception which was not the ExpectedTestException while running the test task.", e);
- Assert.fail("Test caused exception.");
+ LOG.info("Exception which was not the ExpectedTestException while running the test task.", e);
+ Assert.fail("Test caused exception: " + e.getMessage());
}
this.outList.clear();