You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by su...@apache.org on 2015/05/21 14:58:58 UTC
falcon git commit: FALCON-1228. testSubscriber test of
JMSMessageConsumerTest fails at a particular scenario. Contributed by Suhas
Vasu
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 <su...@inmobi.com>
Authored: Thu May 21 18:28:41 2015 +0530
Committer: Suhas Vasu <su...@inmobi.com>
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");