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 <[email protected]> Authored: Fri Oct 23 15:34:28 2015 +0530 Committer: Pallavi Rao <[email protected]> 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); }
