Repository: falcon Updated Branches: refs/heads/master 24d28a71b -> a5f707b98
FALCON-1228. testSubscriber test of JMSMessageConsumerTest fails at a particular scenario. Contributed by Suhas Vasu Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/a5f707b9 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/a5f707b9 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/a5f707b9 Branch: refs/heads/master Commit: a5f707b981abc231146bc91a1617db399c7d4b2d Parents: 24d28a7 Author: Suhas Vasu <[email protected]> Authored: Thu May 21 18:28:41 2015 +0530 Committer: Suhas Vasu <[email protected]> Committed: Thu May 21 18:28:41 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 5 ++++- .../org/apache/falcon/messaging/JMSMessageConsumerTest.java | 6 +----- 2 files changed, 5 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/a5f707b9/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index a47e98c..cb8c7a2 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -25,9 +25,12 @@ Trunk (Unreleased) are inconsistent(Ajay Yadava) OPTIMIZATIONS + FALCON-1228 testSubscriber test of JMSMessageConsumerTest fails at a particular scenario + (Suhas Vasu) BUG FIXES - FALCON-1051 Lineage apis broken for falcon setup in distributed mode(Pavan Kumar Kolamuri via Ajay Yadava) + FALCON-1051 Lineage apis broken for falcon setup in distributed mode + (Pavan Kumar Kolamuri via Ajay Yadava) FALCON-1165 Falcon restart failed, if defined service in cluster entity is unreachable (Peeyush Bishnoi via Ajay Yadava) http://git-wip-us.apache.org/repos/asf/falcon/blob/a5f707b9/messaging/src/test/java/org/apache/falcon/messaging/JMSMessageConsumerTest.java ---------------------------------------------------------------------- diff --git a/messaging/src/test/java/org/apache/falcon/messaging/JMSMessageConsumerTest.java b/messaging/src/test/java/org/apache/falcon/messaging/JMSMessageConsumerTest.java index fa9ecbf..9d49b25 100644 --- a/messaging/src/test/java/org/apache/falcon/messaging/JMSMessageConsumerTest.java +++ b/messaging/src/test/java/org/apache/falcon/messaging/JMSMessageConsumerTest.java @@ -76,8 +76,6 @@ public class JMSMessageConsumerTest { for (int i = 0; i < 3; i++) { WorkflowExecutionContext context = WorkflowExecutionContext.create( getMockFalconMessage(i), WorkflowExecutionContext.Type.POST_PROCESSING); - context.serialize(WorkflowExecutionContext.getFilePath("/tmp/log", "process1", - "process", WorkflowExecutionContext.EntityOperations.GENERATE)); MapMessage message = session.createMapMessage(); for (Map.Entry<WorkflowExecutionArgs, String> entry : context.entrySet()) { @@ -90,8 +88,6 @@ public class JMSMessageConsumerTest { WorkflowExecutionContext context = WorkflowExecutionContext.create( getMockFalconMessage(5), WorkflowExecutionContext.Type.POST_PROCESSING); - context.serialize(WorkflowExecutionContext.getFilePath("/tmp/log", "process1", - "process", WorkflowExecutionContext.EntityOperations.GENERATE)); MapMessage mapMessage = session.createMapMessage(); for (Map.Entry<WorkflowExecutionArgs, String> entry : context.entrySet()) { @@ -113,7 +109,7 @@ public class JMSMessageConsumerTest { "/clicks/hour/00/0" + i); message.put(WorkflowExecutionArgs.OUTPUT_FEED_NAMES.getName(), "clicks"); message.put(WorkflowExecutionArgs.LOG_FILE.getName(), "/logfile"); - message.put(WorkflowExecutionArgs.LOG_DIR.getName(), "/tmp/log"); + message.put(WorkflowExecutionArgs.LOG_DIR.getName(), "/tmp/falcon-log"); message.put(WorkflowExecutionArgs.NOMINAL_TIME.getName(), "2012-10-10-10-10"); message.put(WorkflowExecutionArgs.OPERATION.getName(), "GENERATE"); message.put(WorkflowExecutionArgs.RUN_ID.getName(), "0");
