IGNITE-1477: Fixed.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/dc44a2a7 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/dc44a2a7 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/dc44a2a7 Branch: refs/heads/master Commit: dc44a2a78ce90f5fcab82c0b39d6888724778181 Parents: c0e1ac1 Author: vozerov-gridgain <voze...@gridgain.com> Authored: Tue Sep 15 10:42:15 2015 +0300 Committer: vozerov-gridgain <voze...@gridgain.com> Committed: Tue Sep 15 10:42:15 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/hadoop/igfs/HadoopIgfsWrapper.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/dc44a2a7/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsWrapper.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsWrapper.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsWrapper.java index 01189f7..857db71 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsWrapper.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsWrapper.java @@ -79,7 +79,7 @@ public class HadoopIgfsWrapper implements HadoopIgfs { * @param log Current logger. */ public HadoopIgfsWrapper(String authority, String logDir, Configuration conf, Log log, String user) - throws IOException { + throws IOException { try { this.authority = authority; this.endpoint = new HadoopIgfsEndpoint(authority); @@ -351,7 +351,9 @@ public class HadoopIgfsWrapper implements HadoopIgfs { return curDelegate; // 2. Guess that we are in the same VM. - if (!parameter(conf, PARAM_IGFS_ENDPOINT_NO_EMBED, authority, false)) { + boolean skipInProc = parameter(conf, PARAM_IGFS_ENDPOINT_NO_EMBED, authority, false); + + if (!skipInProc) { IgfsEx igfs = null; if (endpoint.grid() == null) { @@ -471,7 +473,7 @@ public class HadoopIgfsWrapper implements HadoopIgfs { return curDelegate; } else { - SB errMsg = new SB("Failed to connect to IGFS [endpoint=" + authority + ", attempts=["); + SB errMsg = new SB("Failed to connect to IGFS [endpoint=igfs://" + authority + ", attempts=["); if (errShmem != null) errMsg.a("[type=SHMEM, port=" + endpoint.port() + ", err=" + errShmem + "], ");