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 <[email protected]> Authored: Fri Oct 21 11:23:44 2016 +0200 Committer: Robert Metzger <[email protected]> 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();
