You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by sh...@apache.org on 2013/09/19 12:41:03 UTC

git commit: FALCON-128 Feed replication post processing log mover error. Contributed by Shweth GS

Updated Branches:
  refs/heads/master 518dc8952 -> 5e8238bcd


FALCON-128 Feed replication post processing log mover error. Contributed by Shweth GS


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

Branch: refs/heads/master
Commit: 5e8238bcdf4dca74a6cc5e45783ff1a400b8eebe
Parents: 518dc89
Author: Shwetha GS <sh...@gmail.com>
Authored: Thu Sep 19 16:10:53 2013 +0530
Committer: Shwetha GS <sh...@gmail.com>
Committed: Thu Sep 19 16:10:53 2013 +0530

----------------------------------------------------------------------
 CHANGES.txt                                                   | 2 ++
 .../java/org/apache/falcon/workflow/FalconPostProcessing.java | 7 +++++--
 2 files changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/5e8238bc/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 48e19d0..60a0afb 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -28,6 +28,8 @@ Trunk (Unreleased)
     Srikanth Sundarrajan)
 
   BUG FIXES
+    FALCON-128 Feed replication post processing log mover error. (Shwetha GS)
+
     FALCON-127 Fix test issues after FALCON-107. (Shwetha GS via Srikanth
     Sundarrajan)
 

http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/5e8238bc/oozie/src/main/java/org/apache/falcon/workflow/FalconPostProcessing.java
----------------------------------------------------------------------
diff --git a/oozie/src/main/java/org/apache/falcon/workflow/FalconPostProcessing.java b/oozie/src/main/java/org/apache/falcon/workflow/FalconPostProcessing.java
index 914828b..21a2f8e 100644
--- a/oozie/src/main/java/org/apache/falcon/workflow/FalconPostProcessing.java
+++ b/oozie/src/main/java/org/apache/falcon/workflow/FalconPostProcessing.java
@@ -18,6 +18,7 @@
 package org.apache.falcon.workflow;
 
 import org.apache.commons.cli.*;
+import org.apache.commons.lang.StringUtils;
 import org.apache.falcon.logging.LogMover;
 import org.apache.falcon.messaging.MessageProducer;
 import org.apache.hadoop.conf.Configuration;
@@ -172,8 +173,10 @@ public class FalconPostProcessing extends Configured implements Tool {
     }
 
     private void addArg(List<String> args, CommandLine cmd, Arg arg) {
-        args.add("-" + arg.getOptionName());
-        args.add(arg.getOptionValue(cmd));
+        if (StringUtils.isNotEmpty(arg.getOptionValue(cmd))) {
+            args.add("-" + arg.getOptionName());
+            args.add(arg.getOptionValue(cmd));
+        }
     }
 
     private static CommandLine getCommand(String[] arguments)