Repository: incubator-ignite Updated Branches: refs/heads/ignite-218 c3837a7ad -> c79d26a22
# cleanup Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c79d26a2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c79d26a2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c79d26a2 Branch: refs/heads/ignite-218 Commit: c79d26a22e5e0ec58123147cd95b6e1849751c94 Parents: c3837a7 Author: iveselovskiy <iveselovs...@gridgain.com> Authored: Fri May 29 22:12:31 2015 +0300 Committer: iveselovskiy <iveselovs...@gridgain.com> Committed: Fri May 29 22:12:31 2015 +0300 ---------------------------------------------------------------------- .../hadoop/taskexecutor/HadoopRunnableTask.java | 30 -------------------- 1 file changed, 30 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c79d26a2/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 ac141a9..92d1cb8 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 @@ -105,36 +105,6 @@ public abstract class HadoopRunnableTask implements Callable<Void> { user = IgfsUtils.fixUserName(user); return callImpl(user); - -// String ugiUser; -// try { -// UserGroupInformation currUser = UserGroupInformation.getCurrentUser(); -// -// ugiUser = currUser.getShortUserName(); -// } -// catch (IOException ioe) { -// throw new IgniteCheckedException(ioe); -// } -// -// if (F.eq(user, ugiUser)) -// // if current UGI context user is the same, do direct call: -// return callImpl(); -// else { -// // do the call in the context of 'user': -// try { -// final String ticketCachePath = getJobProperty(CommonConfigurationKeys.KERBEROS_TICKET_CACHE_PATH); -// -// UserGroupInformation ugi = UserGroupInformation.getBestUGI(ticketCachePath, user); -// -// return ugi.doAs(new PrivilegedExceptionAction<Void>() { -// @Override public Void run() throws IgniteCheckedException { -// return callImpl(); -// } -// }); -// } catch (IOException | InterruptedException e) { -// throw new IgniteCheckedException(e); -// } -// } } // /**
