You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by pa...@apache.org on 2015/10/23 12:35:30 UTC
falcon git commit: FALCON-1555 succeeded-post-processing action fails
in Oozie uber mode (by Pragya Mittal)
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 <pa...@inmobi.com>
Authored: Fri Oct 23 16:02:00 2015 +0530
Committer: Pallavi Rao <pa...@inmobi.com>
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);
}