falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rostafiyc...@apache.org
Subject [2/2] git commit: FALCON-737 In NoOutputProcessTest print info before assertion. Contributed by Raghav Kumar Gautam
Date Thu, 18 Sep 2014 13:24:36 GMT
FALCON-737 In NoOutputProcessTest print info before assertion. Contributed by Raghav Kumar
Gautam


Project: http://git-wip-us.apache.org/repos/asf/incubator-falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-falcon/commit/7dbec734
Tree: http://git-wip-us.apache.org/repos/asf/incubator-falcon/tree/7dbec734
Diff: http://git-wip-us.apache.org/repos/asf/incubator-falcon/diff/7dbec734

Branch: refs/heads/master
Commit: 7dbec734e047b6dd039eda9ecef06208fd989fb4
Parents: 73ce410
Author: Ruslan Ostafiychuk <rostafiychuk@apache.org>
Authored: Thu Sep 18 16:24:00 2014 +0300
Committer: Ruslan Ostafiychuk <rostafiychuk@apache.org>
Committed: Thu Sep 18 16:24:00 2014 +0300

----------------------------------------------------------------------
 falcon-regression/CHANGES.txt                           |  2 ++
 .../apache/falcon/regression/NoOutputProcessTest.java   | 12 ++++++------
 2 files changed, 8 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/7dbec734/falcon-regression/CHANGES.txt
----------------------------------------------------------------------
diff --git a/falcon-regression/CHANGES.txt b/falcon-regression/CHANGES.txt
index 3b4ec02..2d8d631 100644
--- a/falcon-regression/CHANGES.txt
+++ b/falcon-regression/CHANGES.txt
@@ -73,6 +73,8 @@ Trunk (Unreleased)
    FALCON-681 delete duplicate feed retention test from falcon regression (SamarthG)
 
   BUG FIXES
+   FALCON-737 In NoOutputProcessTest print info before assertion (Raghav Kumar Gautam via
Ruslan Ostafiychuk)
+
    FALCON-736 OneNonCatInputOneHCatOutput test fails because of change in parameter name
(Raghav Kumar Gautam
    via Ruslan Ostafiychuk)
 

http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/7dbec734/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/NoOutputProcessTest.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/NoOutputProcessTest.java
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/NoOutputProcessTest.java
index 45714ce..871e8dc 100644
--- a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/NoOutputProcessTest.java
+++ b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/NoOutputProcessTest.java
@@ -114,10 +114,10 @@ public class NoOutputProcessTest extends BaseTestClass {
         //wait for all the instances to complete
         InstanceUtil.waitTillInstanceReachState(clusterOC, bundles[0].getProcessName(), 3,
             CoordinatorAction.Status.SUCCEEDED, EntityType.PROCESS);
-        Assert.assertEquals(messageConsumer.getReceivedMessages().size(), 3,
-            " Message for all the 3 instance not found");
         messageConsumer.interrupt();
         Util.printMessageData(messageConsumer);
+        Assert.assertEquals(messageConsumer.getReceivedMessages().size(), 3,
+            " Message for all the 3 instance not found");
     }
 
     /**
@@ -138,14 +138,14 @@ public class NoOutputProcessTest extends BaseTestClass {
         //wait for all the instances to complete
         InstanceUtil.waitTillInstanceReachState(clusterOC, bundles[0].getProcessName(), 3,
             CoordinatorAction.Status.SUCCEEDED, EntityType.PROCESS);
-        Assert.assertEquals(consumerEntityMsg.getReceivedMessages().size(), 3,
-            " Message for all the 3 instance not found");
-        Assert.assertEquals(consumerProcessMsg.getReceivedMessages().size(), 3,
-            " Message for all the 3 instance not found");
         consumerEntityMsg.interrupt();
         consumerProcessMsg.interrupt();
         Util.printMessageData(consumerEntityMsg);
         Util.printMessageData(consumerProcessMsg);
+        Assert.assertEquals(consumerEntityMsg.getReceivedMessages().size(), 3,
+            " Message for all the 3 instance not found");
+        Assert.assertEquals(consumerProcessMsg.getReceivedMessages().size(), 3,
+            " Message for all the 3 instance not found");
     }
 
     @AfterClass(alwaysRun = true)


Mime
View raw message