Repository: falcon Updated Branches: refs/heads/master a0911bd82 -> a3e2320f8
FALCON-1551 Implement setWorkingDir Method in JailedFileSystem(Pavan Kolamuri) Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/a3e2320f Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/a3e2320f Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/a3e2320f Branch: refs/heads/master Commit: a3e2320f8e9bf4e9ef14e33b474e67c3ff240124 Parents: a0911bd Author: Pallavi Rao <[email protected]> Authored: Wed Oct 21 11:15:56 2015 +0530 Committer: Pallavi Rao <[email protected]> Committed: Wed Oct 21 11:15:56 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../org/apache/falcon/hadoop/JailedFileSystem.java | 15 +++++++++++++-- 2 files changed, 15 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/a3e2320f/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index a4dc1c8..d5e0bf0 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -71,6 +71,8 @@ Trunk (Unreleased) FALCON-1403 Revisit IT cleanup and teardown(Narayan Periwal via Pallavi Rao) BUG FIXES + 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) FALCON-1530 SLAMonitoring API is not honouring delete feature(Ajay Yadava). http://git-wip-us.apache.org/repos/asf/falcon/blob/a3e2320f/hadoop-dependencies/src/main/java/org/apache/falcon/hadoop/JailedFileSystem.java ---------------------------------------------------------------------- diff --git a/hadoop-dependencies/src/main/java/org/apache/falcon/hadoop/JailedFileSystem.java b/hadoop-dependencies/src/main/java/org/apache/falcon/hadoop/JailedFileSystem.java index d5b2eb3..27b5a9e 100644 --- a/hadoop-dependencies/src/main/java/org/apache/falcon/hadoop/JailedFileSystem.java +++ b/hadoop-dependencies/src/main/java/org/apache/falcon/hadoop/JailedFileSystem.java @@ -43,9 +43,11 @@ public class JailedFileSystem extends FileSystem { private URI uri; private String basePath; private LocalFileSystem localFS; + private Path workingDir; public JailedFileSystem() { localFS = new LocalFileSystem(); + this.workingDir = new Path("/user", System.getProperty("user.name")); } @Override @@ -128,12 +130,21 @@ public class JailedFileSystem extends FileSystem { @Override public void setWorkingDirectory(Path newDir) { - throw new UnsupportedOperationException(); + if (newDir != null) { + workingDir = makeAbsolute(newDir); + } + } + + private Path makeAbsolute(Path path) { + if (path.isAbsolute()) { + return path; + } + return new Path(workingDir, path); } @Override public Path getWorkingDirectory() { - return new Path("/user/" + System.getProperty("user.name")); + return workingDir; } @Override
