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:37 UTC
falcon git commit: FALCON-1555 succeeded-post-processing action fails
in Oozie uber mode (Pragya Mittal)
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 <pa...@inmobi.com>
Authored: Fri Oct 23 15:34:28 2015 +0530
Committer: Pallavi Rao <pa...@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);
}