IGNITE-3165: Hadoop: Fixed incorrect resource extension resolution.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a4ae5fe5 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a4ae5fe5 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a4ae5fe5 Branch: refs/heads/ignite-3163 Commit: a4ae5fe59099e8ed71aa9fe795c2689bb6dc73b3 Parents: 3d6e179 Author: vozerov-gridgain <[email protected]> Authored: Wed May 18 14:47:45 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Wed May 18 14:47:45 2016 +0300 ---------------------------------------------------------------------- .../processors/hadoop/v2/HadoopV2JobResourceManager.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a4ae5fe5/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2JobResourceManager.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2JobResourceManager.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2JobResourceManager.java index 769cd9e..67ab600 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2JobResourceManager.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2JobResourceManager.java @@ -190,21 +190,17 @@ class HadoopV2JobResourceManager { Collection<String> res = new ArrayList<>(); for (Object pathObj : files) { - String locName = null; Path srcPath; if (pathObj instanceof URI) { URI uri = (URI)pathObj; - locName = uri.getFragment(); - srcPath = new Path(uri); } else srcPath = (Path)pathObj; - if (locName == null) - locName = srcPath.getName(); + String locName = srcPath.getName(); File dstPath = new File(jobLocDir.getAbsolutePath(), locName);
