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/05/29 21:12:54 UTC

incubator-ignite git commit: # cleanup

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 <iv...@gridgain.com>
Authored: Fri May 29 22:12:31 2015 +0300
Committer: iveselovskiy <iv...@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);
-//            }
-//        }
     }
 
 //    /**