falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pall...@apache.org
Subject falcon git commit: FALCON-1496 [TEST] Flaky FalconPostProcessingTest
Date Tue, 16 Feb 2016 04:33:21 GMT
Repository: falcon
Updated Branches:
  refs/heads/master 67c29705a -> 9b4acf640


FALCON-1496 [TEST] Flaky FalconPostProcessingTest

Author: Pallavi Rao <pallavi.rao@inmobi.com>

Reviewers: Deeepak Barr <deepak.barr@gmail.com>

Closes #41 from pallavi-rao/1496


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

Branch: refs/heads/master
Commit: 9b4acf640bfef17f1284ef5cff72678e75397766
Parents: 67c2970
Author: Pallavi Rao <pallavi.rao@inmobi.com>
Authored: Tue Feb 16 10:03:09 2016 +0530
Committer: Pallavi Rao <pallavi.rao@inmobi.com>
Committed: Tue Feb 16 10:03:09 2016 +0530

----------------------------------------------------------------------
 .../falcon/oozie/workflow/FalconPostProcessingTest.java  | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/9b4acf64/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java
----------------------------------------------------------------------
diff --git a/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java
b/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java
index 171068a..1c50a97 100644
--- a/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java
+++ b/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java
@@ -217,6 +217,9 @@ public class FalconPostProcessingTest {
     }
 
     private void verifyMesssage(MessageConsumer consumer) throws JMSException {
+
+        String[] actualFeedNames = new String[outputFeedPaths.length];
+        String[] actualFeedPaths = new String[outputFeedPaths.length];
         for (int index = 0; index < outputFeedPaths.length; ++index) {
             // receive call is blocking
             MapMessage m = (MapMessage) consumer.receive();
@@ -224,11 +227,11 @@ public class FalconPostProcessingTest {
             System.out.println("Received JMS message {}" + m.toString());
             System.out.println("Consumed: " + m.toString());
             assertMessage(m);
-            Assert.assertEquals(m.getString(WorkflowExecutionArgs.OUTPUT_FEED_NAMES.getName()),
-                    outputFeedNames[index]);
-            Assert.assertEquals(m.getString(WorkflowExecutionArgs.OUTPUT_FEED_PATHS.getName()),
-                    outputFeedPaths[index]);
+            actualFeedNames[index] = m.getString(WorkflowExecutionArgs.OUTPUT_FEED_NAMES.getName());
+            actualFeedPaths[index] = m.getString(WorkflowExecutionArgs.OUTPUT_FEED_PATHS.getName());
         }
+        Assert.assertEqualsNoOrder(actualFeedNames, outputFeedNames);
+        Assert.assertEqualsNoOrder(actualFeedPaths, outputFeedPaths);
     }
 
     private void assertMessage(MapMessage m) throws JMSException {


Mime
View raw message