Class org.apache.hadoop.mapred.TaskTracker

Added interface org.apache.hadoop.mapred.TaskTrackerMXBean.

Changed Constructors
TaskTracker(JobConf)	Change in exceptions thrown from java.io.IOException to (java.io.IOException, java.lang.InterruptedException).	Start with the local machine name and the default JobTracker

 

Added Methods
void fatalError(TaskAttemptID, String, JvmContext)	A child task had a fatal error.
String getConfigVersion()
String getHostname()
int getHttpPort()
String getJobCacheSubdir(String)
String getJobJarFile(String, String)
String getJobTrackerUrl()
String getLocalJobDir(String, String)
String getLocalTaskDir(String, String, String)
String getLocalTaskDir(String, String, String, boolean)
String getPrivateDistributedCacheDir(String)
String getPublicDistributedCacheDir()
int getRpcPort()
TaskController getTaskController()
String getTasksInfoJson()
String getUserDir(String)
String getVersion()
boolean isHealthy()
void updatePrivateDistributedCacheSizes(JobID, long[])

 

Changed Methods
boolean canCommit(TaskAttemptID, JvmContext)	Change in signature from TaskAttemptID to (TaskAttemptID, JvmContext). Change in exceptions thrown from no exceptions to java.io.IOException.	Child checking whether it can commit
void close()	Change in exceptions thrown from java.io.IOException to (java.io.IOException, java.lang.InterruptedException).	Close down the TaskTracker and all its components.
void commitPending(TaskAttemptID, TaskStatus, JvmContext)	Change in signature from (TaskAttemptID, TaskStatus) to (TaskAttemptID, TaskStatus, JvmContext).	Task is reporting that it is in commit_pending and it is waiting for the commit Response
void done(TaskAttemptID, JvmContext)	Change in signature from TaskAttemptID to (TaskAttemptID, JvmContext).	The task is done.
void fsError(TaskAttemptID, String, JvmContext)	Change in signature from (TaskAttemptID, String) to (TaskAttemptID, String, JvmContext).	A child task had a local filesystem error.
Class getInstrumentationClass(Configuration)	Change in return type from (Class) to Class.
MapTaskCompletionEventsUpdate getMapCompletionEvents(JobID, int, int, TaskAttemptID, JvmContext)	Change in signature from (JobID, int, int, TaskAttemptID) to (JobID, int, int, TaskAttemptID, JvmContext).
JvmTask getTask(JvmContext)	Change in signature from JVMId to JvmContext.	Called upon startup by the child process to fetch Task data.
boolean ping(TaskAttemptID, JvmContext)	Change in signature from TaskAttemptID to (TaskAttemptID, JvmContext).	Child checking to see if we're alive.
void reportDiagnosticInfo(TaskAttemptID, String, JvmContext)	Change in signature from (TaskAttemptID, String) to (TaskAttemptID, String, JvmContext).	Called when the task dies before completion and we want to report back diagnostic info
void reportNextRecordRange(TaskAttemptID, Range, JvmContext)	Change in signature from (TaskAttemptID, Range) to (TaskAttemptID, Range, JvmContext).
void setInstrumentationClass(Configuration, Class)	Change in signature from (Configuration, Class) to (Configuration, Class).
void shuffleError(TaskAttemptID, String, JvmContext)	Change in signature from (TaskAttemptID, String) to (TaskAttemptID, String, JvmContext).	A reduce-task failed to shuffle the map-outputs.
void shutdown()	Change in exceptions thrown from java.io.IOException to (java.io.IOException, java.lang.InterruptedException).
boolean statusUpdate(TaskAttemptID, TaskStatus, JvmContext)	Change in signature from (TaskAttemptID, TaskStatus) to (TaskAttemptID, TaskStatus, JvmContext).	Called periodically to report Task progress from 0.0 to 1.0.

 

Added Fields
String SUBDIR
String TT_KEYTAB_FILE
String TT_LOG_TMP_DIR
String TT_RESOURCE_CALCULATOR_PLUGIN
String TT_USER_NAME