Repository: incubator-ignite Updated Branches: refs/heads/ignite-218 4fae10730 -> 04653a0de
# IGNITE-218: Review. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/04653a0d Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/04653a0d Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/04653a0d Branch: refs/heads/ignite-218 Commit: 04653a0de38fd3c7358d05f982e5c8a1a8cc7c86 Parents: 4fae107 Author: vozerov-gridgain <[email protected]> Authored: Mon Jun 1 13:34:33 2015 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Mon Jun 1 13:34:33 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/igfs/IgfsSecondaryFileSystemImpl.java | 2 +- .../processors/hadoop/taskexecutor/HadoopRunnableTask.java | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04653a0d/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemImpl.java index b8095b8..44ee90f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemImpl.java @@ -121,6 +121,6 @@ class IgfsSecondaryFileSystemImpl implements IgfsSecondaryFileSystem { /** {@inheritDoc} */ @Override public void close() throws IgniteException { - igfs.stop(true); + // No-op. } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04653a0d/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopRunnableTask.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopRunnableTask.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopRunnableTask.java index 512d7ef..f091e8f 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopRunnableTask.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopRunnableTask.java @@ -106,11 +106,12 @@ public abstract class HadoopRunnableTask implements Callable<Void> { assert user != null; + // TODO: Inclapsulate user name into HadoopTaskContext. ctx = job.getTaskContext(info); return ctx.runAs(user, new Callable<Void>() { @Override public Void call() throws Exception { - runTaskImpl(); + call0(); return null; } @@ -121,7 +122,7 @@ public abstract class HadoopRunnableTask implements Callable<Void> { * Implements actual task running. * @throws IgniteCheckedException */ - void runTaskImpl() throws IgniteCheckedException { + void call0() throws IgniteCheckedException { execStartTs = U.currentTimeMillis(); Throwable err = null;
