Repository: incubator-ignite Updated Branches: refs/heads/ignite-1173 [created] ae62426b5
# IG-1173: debug info added. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ae62426b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ae62426b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ae62426b Branch: refs/heads/ignite-1173 Commit: ae62426b56309f5a7cbeb5a90f41eb66000ff106 Parents: 7ed4d15 Author: iveselovskiy <iveselovs...@gridgain.com> Authored: Fri Jul 31 12:21:20 2015 +0300 Committer: iveselovskiy <iveselovs...@gridgain.com> Committed: Fri Jul 31 12:21:20 2015 +0300 ---------------------------------------------------------------------- .../processors/hadoop/v2/HadoopV2JobResourceManager.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae62426b/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 912cc3f..8aca440 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 @@ -224,10 +224,16 @@ class HadoopV2JobResourceManager { throw new IOException("Failed to create directory " + "[path=" + archivesPath + ", jobId=" + jobId + ']'); + // locName = dsdgen + // archiveFile = gridgain-community-hadoop-1.3.3-rc1/work/hadoop/node-0d52cede-c2ad-406b-bd2b-b22d96d071d6/job_0d52cede-c2ad-406b-bd2b-b22d96d071d6_1/.cached-archives/dsdgen File archiveFile = new File(archivesPath, locName); + // srcPath = /tmp/-2be2732670ff4dfb167ff6671307bd82.jar#dsdgen + // dstPath = /home/ivan/hive-server-2/gridgain-community-hadoop-1.3.3-rc1/work/hadoop/node-0d52cede-c2ad-406b-bd2b-b22d96d071d6/job_0d52cede-c2ad-406b-bd2b-b22d96d071d6_1/dsdgen + // this somehow works, though fragment is not cut off: FileUtil.copy(srcFs, srcPath, dstFs, new Path(archiveFile.toString()), false, cfg); + // archiveNameLC = dsdgen String archiveNameLC = archiveFile.getName().toLowerCase(); if (archiveNameLC.endsWith(".jar")) @@ -239,6 +245,7 @@ class HadoopV2JobResourceManager { archiveNameLC.endsWith(".tar")) FileUtil.unTar(archiveFile, dstPath); else + // ***** fail there: throw new IOException("Cannot unpack archive [path=" + srcPath + ", jobId=" + jobId + ']'); } else
