You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/06/01 12:34:24 UTC
incubator-ignite git commit: # IGNITE-218: Review.
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 <vo...@gridgain.com>
Authored: Mon Jun 1 13:34:33 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
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;