MAPREDUCE-6256. Removed unused private methods in o.a.h.mapreduce.Job.java. Contributed by Naganarasimha G R.
This commit is contained in:
parent
ef950ea1c0
commit
3338f6d907
|
@ -291,6 +291,9 @@ Release 2.7.0 - UNRELEASED
|
||||||
MAPREDUCE-6255. Fix JobCounter's format to use grouping separator.
|
MAPREDUCE-6255. Fix JobCounter's format to use grouping separator.
|
||||||
(Ryu Kobayashi via ozawa)
|
(Ryu Kobayashi via ozawa)
|
||||||
|
|
||||||
|
MAPREDUCE-6256. Removed unused private methods in o.a.h.mapreduce.Job.java.
|
||||||
|
(Naganarasimha G R via ozawa)
|
||||||
|
|
||||||
OPTIMIZATIONS
|
OPTIMIZATIONS
|
||||||
|
|
||||||
MAPREDUCE-6169. MergeQueue should release reference to the current item
|
MAPREDUCE-6169. MergeQueue should release reference to the current item
|
||||||
|
|
|
@ -98,9 +98,6 @@ public class Job extends JobContextImpl implements JobContext {
|
||||||
"mapreduce.client.genericoptionsparser.used";
|
"mapreduce.client.genericoptionsparser.used";
|
||||||
public static final String SUBMIT_REPLICATION =
|
public static final String SUBMIT_REPLICATION =
|
||||||
"mapreduce.client.submit.file.replication";
|
"mapreduce.client.submit.file.replication";
|
||||||
private static final String TASKLOG_PULL_TIMEOUT_KEY =
|
|
||||||
"mapreduce.client.tasklog.timeout";
|
|
||||||
private static final int DEFAULT_TASKLOG_TIMEOUT = 60000;
|
|
||||||
|
|
||||||
@InterfaceStability.Evolving
|
@InterfaceStability.Evolving
|
||||||
public static enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL }
|
public static enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL }
|
||||||
|
@ -341,10 +338,6 @@ public class Job extends JobContextImpl implements JobContext {
|
||||||
return status;
|
return status;
|
||||||
}
|
}
|
||||||
|
|
||||||
private void setStatus(JobStatus status) {
|
|
||||||
this.status = status;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the current state of the Job.
|
* Returns the current state of the Job.
|
||||||
*
|
*
|
||||||
|
@ -1393,46 +1386,6 @@ public class Job extends JobContextImpl implements JobContext {
|
||||||
return success;
|
return success;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return true if the profile parameters indicate that this is using
|
|
||||||
* hprof, which generates profile files in a particular location
|
|
||||||
* that we can retrieve to the client.
|
|
||||||
*/
|
|
||||||
private boolean shouldDownloadProfile() {
|
|
||||||
// Check the argument string that was used to initialize profiling.
|
|
||||||
// If this indicates hprof and file-based output, then we're ok to
|
|
||||||
// download.
|
|
||||||
String profileParams = getProfileParams();
|
|
||||||
|
|
||||||
if (null == profileParams) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Split this on whitespace.
|
|
||||||
String [] parts = profileParams.split("[ \\t]+");
|
|
||||||
|
|
||||||
// If any of these indicate hprof, and the use of output files, return true.
|
|
||||||
boolean hprofFound = false;
|
|
||||||
boolean fileFound = false;
|
|
||||||
for (String p : parts) {
|
|
||||||
if (p.startsWith("-agentlib:hprof") || p.startsWith("-Xrunhprof")) {
|
|
||||||
hprofFound = true;
|
|
||||||
|
|
||||||
// This contains a number of comma-delimited components, one of which
|
|
||||||
// may specify the file to write to. Make sure this is present and
|
|
||||||
// not empty.
|
|
||||||
String [] subparts = p.split(",");
|
|
||||||
for (String sub : subparts) {
|
|
||||||
if (sub.startsWith("file=") && sub.length() != "file=".length()) {
|
|
||||||
fileFound = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return hprofFound && fileFound;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void printTaskEvents(TaskCompletionEvent[] events,
|
private void printTaskEvents(TaskCompletionEvent[] events,
|
||||||
Job.TaskStatusFilter filter, boolean profiling, IntegerRanges mapRanges,
|
Job.TaskStatusFilter filter, boolean profiling, IntegerRanges mapRanges,
|
||||||
IntegerRanges reduceRanges) throws IOException, InterruptedException {
|
IntegerRanges reduceRanges) throws IOException, InterruptedException {
|
||||||
|
|
Loading…
Reference in New Issue