Repository: falcon Updated Branches: refs/heads/master 3fd11e80e -> 3dc7efe50
FALCON-2290 Change staging directory for entity creation while extension job submission Author: Pracheer Agarwal <[email protected]> Author: Pracheer Agarwal <[email protected]> Author: Pracheer Agarwal <[email protected]> Author: Pracheer <[email protected]> Reviewers: @pallavi-rao Closes #372 from PracheerAgarwal/FALCON-2290 and squashes the following commits: 301ae0a [Pracheer Agarwal] FALCON-2290 adding timestamp to staging directory beece2d [Pracheer Agarwal] FALCON-2290 Change staging directory for entity creation while extension job submission 7f3932c [Pracheer Agarwal] Merge branch 'master' of https://github.com/PracheerAgarwal/falcon 2e12279 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 41da933 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon fc6ef2b [Pracheer] Merge branch 'master' of https://github.com/apache/falcon 7814fba [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon ba60452 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon ed65aa0 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 9ff05df [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 9c2f0a5 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 9cd8c17 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 778c579 [Pracheer Agarwal] Merge branch 'master' of https://github.com/PracheerAgarwal/falcon e39808d [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon a932633 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon fda3b28 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon a93d71a [Pracheer Agarwal] Merge branch 'master' of https://github.com/PracheerAgarwal/falcon e3728d5 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 066c8e2 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon b20f044 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 7f572a1 [Pracheer Agarwal] Merge branch 'master' of https://github.com/apache/falcon 46042fd [Pracheer Agarwal] Merge branch 'master' of https://github.com/PracheerAgarwal/falcon daa3ffc [Pracheer Agarwal] FALCON-2225 extension owner added for trusted extensions 622cae4 [Pracheer Agarwal] FALCON-2225 extension owner added for trusted extensions Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/3dc7efe5 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/3dc7efe5 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/3dc7efe5 Branch: refs/heads/master Commit: 3dc7efe507d188543f08d6fafdb7b66de8f05703 Parents: 3fd11e8 Author: Pracheer Agarwal <[email protected]> Authored: Tue Feb 28 13:07:34 2017 +0530 Committer: Pallavi Rao <[email protected]> Committed: Tue Feb 28 13:07:34 2017 +0530 ---------------------------------------------------------------------- client/src/main/java/org/apache/falcon/ExtensionHandler.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/3dc7efe5/client/src/main/java/org/apache/falcon/ExtensionHandler.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/falcon/ExtensionHandler.java b/client/src/main/java/org/apache/falcon/ExtensionHandler.java index e17f8e6..769cd78 100644 --- a/client/src/main/java/org/apache/falcon/ExtensionHandler.java +++ b/client/src/main/java/org/apache/falcon/ExtensionHandler.java @@ -55,6 +55,7 @@ public final class ExtensionHandler { public static final Logger LOG = LoggerFactory.getLogger(ExtensionHandler.class); private static final String UTF_8 = CharEncoding.UTF_8; private static final String TMP_BASE_DIR = String.format("file://%s", System.getProperty("java.io.tmpdir")); + private static final String PATH_SEPARATOR = "_"; private static final String LOCATION = "location"; private static final String TYPE = "type"; private static final String NAME = "extensionName"; @@ -146,8 +147,8 @@ public final class ExtensionHandler { } private static String createStagePath(String extensionName, String jobName) { - String stagePath = TMP_BASE_DIR + File.separator + extensionName + File.separator + jobName - + File.separator + System.currentTimeMillis()/1000; + String stagePath = TMP_BASE_DIR + File.separator + extensionName + PATH_SEPARATOR + jobName + + PATH_SEPARATOR + System.currentTimeMillis()/1000; File tmpPath = new File(stagePath); if (tmpPath.mkdir()) { throw new FalconCLIException("Failed to create stage directory" + tmpPath.toString());
