Repository: falcon Updated Branches: refs/heads/master 67c29705a -> 9b4acf640
FALCON-1496 [TEST] Flaky FalconPostProcessingTest Author: Pallavi Rao <[email protected]> Reviewers: Deeepak Barr <[email protected]> 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 <[email protected]> Authored: Tue Feb 16 10:03:09 2016 +0530 Committer: Pallavi Rao <[email protected]> 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 {
