|
@@ -25,8 +25,6 @@ import org.apache.hadoop.classification.InterfaceStability;
|
|
import org.apache.hadoop.fs.FileSystem;
|
|
import org.apache.hadoop.fs.FileSystem;
|
|
import org.apache.hadoop.security.AccessControlException;
|
|
import org.apache.hadoop.security.AccessControlException;
|
|
import org.apache.hadoop.security.UserGroupInformation;
|
|
import org.apache.hadoop.security.UserGroupInformation;
|
|
-import org.apache.hadoop.util.SystemClock;
|
|
|
|
-import org.apache.hadoop.util.Clock;
|
|
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
@@ -176,7 +174,7 @@ public class MiniMRCluster {
|
|
String[] hosts, UserGroupInformation ugi, JobConf conf,
|
|
String[] hosts, UserGroupInformation ugi, JobConf conf,
|
|
int numTrackerToExclude) throws IOException {
|
|
int numTrackerToExclude) throws IOException {
|
|
this(jobTrackerPort, taskTrackerPort, numTaskTrackers, namenode, numDir,
|
|
this(jobTrackerPort, taskTrackerPort, numTaskTrackers, namenode, numDir,
|
|
- racks, hosts, ugi, conf, numTrackerToExclude, SystemClock.getInstance());
|
|
|
|
|
|
+ racks, hosts, ugi, conf, numTrackerToExclude, new Clock());
|
|
}
|
|
}
|
|
|
|
|
|
public MiniMRCluster(int jobTrackerPort, int taskTrackerPort,
|
|
public MiniMRCluster(int jobTrackerPort, int taskTrackerPort,
|