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-1555 succeeded-post-processing action fails in Oozie uber mode (Pragya Mittal)
Date Fri, 23 Oct 2015 10:35:37 GMT
Repository: falcon
Updated Branches:
  refs/heads/master bc9c2cd31 -> c30fce751


FALCON-1555 succeeded-post-processing action fails in Oozie uber mode (Pragya Mittal)


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

Branch: refs/heads/master
Commit: c30fce7512679b433cedb718c4bf294bcc2fdae2
Parents: bc9c2cd
Author: Pallavi Rao <pallavi.rao@inmobi.com>
Authored: Fri Oct 23 15:34:28 2015 +0530
Committer: Pallavi Rao <pallavi.rao@inmobi.com>
Committed: Fri Oct 23 15:34:28 2015 +0530

----------------------------------------------------------------------
 CHANGES.txt                                            |  2 ++
 .../main/java/org/apache/falcon/hive/HiveDRTool.java   | 13 -------------
 .../falcon/workflow/WorkflowExecutionContext.java      |  1 -
 3 files changed, 2 insertions(+), 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/c30fce75/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 1ce124f..95dd69d 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -90,6 +90,8 @@ Release version: 0.8
     FALCON-1403 Revisit IT cleanup and teardown(Narayan Periwal via Pallavi Rao)
 
   BUG FIXES
+    FALCON-1555 succeeded-post-processing action fails in Oozie uber mode (Pragya Mittal
via Pallavi Rao)
+
     FALCON-1551 Implement setWorkingDir Method in JailedFileSystem(Pavan Kolamuri via Pallavi
Rao)
 
     FALCON-1541 Bundle deploy.properties while packaging falcon (Pragya Mittal via Pallavi
Rao)

http://git-wip-us.apache.org/repos/asf/falcon/blob/c30fce75/addons/hivedr/src/main/java/org/apache/falcon/hive/HiveDRTool.java
----------------------------------------------------------------------
diff --git a/addons/hivedr/src/main/java/org/apache/falcon/hive/HiveDRTool.java b/addons/hivedr/src/main/java/org/apache/falcon/hive/HiveDRTool.java
index bebdb0b..c3d9b5c 100644
--- a/addons/hivedr/src/main/java/org/apache/falcon/hive/HiveDRTool.java
+++ b/addons/hivedr/src/main/java/org/apache/falcon/hive/HiveDRTool.java
@@ -320,19 +320,6 @@ public class HiveDRTool extends Configured implements Tool {
         cleanStagingDirectory();
         cleanInputDir();
         cleanTempFiles();
-        try {
-            if (jobFS != null) {
-                jobFS.close();
-            }
-            if (targetClusterFS != null) {
-                targetClusterFS.close();
-            }
-            if (sourceClusterFS != null) {
-                sourceClusterFS.close();
-            }
-        } catch (IOException e) {
-            LOG.error("Closing FS failed", e);
-        }
     }
 
     private void cleanTempFiles() {

http://git-wip-us.apache.org/repos/asf/falcon/blob/c30fce75/common/src/main/java/org/apache/falcon/workflow/WorkflowExecutionContext.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/falcon/workflow/WorkflowExecutionContext.java
b/common/src/main/java/org/apache/falcon/workflow/WorkflowExecutionContext.java
index b870e3a..9bfc51b 100644
--- a/common/src/main/java/org/apache/falcon/workflow/WorkflowExecutionContext.java
+++ b/common/src/main/java/org/apache/falcon/workflow/WorkflowExecutionContext.java
@@ -469,7 +469,6 @@ public class WorkflowExecutionContext {
                 if (fs.exists(counterFile)) {
                     fs.delete(counterFile, false);
                 }
-                fs.close();
             } catch (IOException e) {
                 LOG.error("Unable to delete counter file: {}", e);
             }


Mime
View raw message