You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by ro...@apache.org on 2014/09/18 15:24:36 UTC
[2/2] git commit: FALCON-737 In NoOutputProcessTest print info before
assertion. Contributed by Raghav Kumar Gautam
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 <ro...@apache.org>
Authored: Thu Sep 18 16:24:00 2014 +0300
Committer: Ruslan Ostafiychuk <ro...@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)