You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/07/31 11:21:52 UTC
incubator-ignite git commit: # IG-1173: debug info added.
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 <iv...@gridgain.com>
Authored: Fri Jul 31 12:21:20 2015 +0300
Committer: iveselovskiy <iv...@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