You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by om...@apache.org on 2011/03/04 05:39:56 UTC
svn commit: r1077646 -
/hadoop/common/branches/branch-0.20-security-patches/src/test/system/java/org/apache/hadoop/mapred/TestNodeDecommissioning.java
Author: omalley
Date: Fri Mar 4 04:39:56 2011
New Revision: 1077646
URL: http://svn.apache.org/viewvc?rev=1077646&view=rev
Log:
commit 15f7ef8bef6f97799cf0e2252ce54c56222758b3
Author: Iyappan Srinivasan <iy...@yahoo-inc.com>
Date: Fri Aug 6 14:17:36 2010 +0000
MAPREDUCE-1890 https://issues.apache.org/jira/secure/attachment/12451428/1890-ydist-security-patch.txt
Modified:
hadoop/common/branches/branch-0.20-security-patches/src/test/system/java/org/apache/hadoop/mapred/TestNodeDecommissioning.java
Modified: hadoop/common/branches/branch-0.20-security-patches/src/test/system/java/org/apache/hadoop/mapred/TestNodeDecommissioning.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.20-security-patches/src/test/system/java/org/apache/hadoop/mapred/TestNodeDecommissioning.java?rev=1077646&r1=1077645&r2=1077646&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.20-security-patches/src/test/system/java/org/apache/hadoop/mapred/TestNodeDecommissioning.java (original)
+++ hadoop/common/branches/branch-0.20-security-patches/src/test/system/java/org/apache/hadoop/mapred/TestNodeDecommissioning.java Fri Mar 4 04:39:56 2011
@@ -78,8 +78,8 @@ public class TestNodeDecommissioning {
@AfterClass
public static void tearDown() throws Exception {
- cluster.tearDown();
cluster.restart();
+ cluster.tearDown();
}
/**
@@ -159,8 +159,8 @@ public class TestNodeDecommissioning {
";bin/hadoop mradmin -refreshNodes;";
LOG.info("refreshNodeCommand is : " + refreshNodeCommand);
try {
- RemoteExecution.executeCommand(testRunningHostName, userName,
- refreshNodeCommand);
+ RemoteExecution.executeCommand(testRunningHostName, userName,
+ refreshNodeCommand);
} catch (Exception e) { e.printStackTrace();}
//Checked whether the node is really decommissioned.
@@ -168,7 +168,7 @@ public class TestNodeDecommissioning {
nodeDecommissionedOrNot = remoteJTClientProxy.
isNodeDecommissioned(ttClientHostName);
- //The TTClient host is removed from the exclude path
+ //The TTClient host is removed from the exclude path
command = "rm " + excludeHostPath;
LOG.info("command is : " + command);
@@ -189,11 +189,11 @@ public class TestNodeDecommissioning {
//Starting that node
String ttClientStart = "export HADOOP_CONF_DIR=" + hadoopConfDir +
"; export HADOOP_HOME=" + hadoopHomeDir + ";cd " + hadoopHomeDir +
- ";bin/hadoop-daemon.sh start tasktracker;";
+ ";kinit -k -t " + keytabForHadoopqaUser +
+ ";bin/hadoop-daemons.sh start tasktracker;";
LOG.info("ttClientStart is : " + ttClientStart);
- RemoteExecution.executeCommand(ttClientHostName, userName,
+ RemoteExecution.executeCommand(jtClientHostName, userName,
ttClientStart);
-
}
}