Repository: falcon Updated Branches: refs/heads/0.8 e8159406b -> 3077fa93d
FALCON-1555 succeeded-post-processing action fails in Oozie uber mode (by Pragya Mittal) Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/3077fa93 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/3077fa93 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/3077fa93 Branch: refs/heads/0.8 Commit: 3077fa93d132bb11def977518b604e4f4d14a5e4 Parents: e815940 Author: Pallavi Rao <[email protected]> Authored: Fri Oct 23 16:02:00 2015 +0530 Committer: Pallavi Rao <[email protected]> Committed: Fri Oct 23 16:02:00 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/3077fa93/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 2feb25e..9fae806 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -75,6 +75,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/3077fa93/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/3077fa93/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); }
