Author: yhemanth
Date: Wed Jul 23 23:41:39 2008
New Revision: 679286
URL: http://svn.apache.org/viewvc?rev=679286&view=rev
Log:
HADOOP-3808. Modified HOD to include RPC port of the JobTracker into the notes
attribute of the resource manager. Contributed by Hemanth Yamijala.
Modified:
hadoop/core/trunk/src/contrib/hod/CHANGES.txt
hadoop/core/trunk/src/contrib/hod/hodlib/Hod/hadoop.py
hadoop/core/trunk/src/contrib/hod/hodlib/Hod/nodePool.py
Modified: hadoop/core/trunk/src/contrib/hod/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hod/CHANGES.txt?rev=679286&r1=679285&r2=679286&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hod/CHANGES.txt (original)
+++ hadoop/core/trunk/src/contrib/hod/CHANGES.txt Wed Jul 23 23:41:39 2008
@@ -29,6 +29,9 @@
HADOOP-3610. Modified HOD to create cluster directory if one does not
exist when using the script option. (Vinod Kumar Vavilapalli via yhemanth)
+ HADOOP-3808. Modified HOD to include RPC port of the JobTracker
+ into the notes attribute of the resource manager. (yhemanth)
+
NEW FEATURES
IMPROVEMENTS
Modified: hadoop/core/trunk/src/contrib/hod/hodlib/Hod/hadoop.py
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hod/hodlib/Hod/hadoop.py?rev=679286&r1=679285&r2=679286&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hod/hodlib/Hod/hadoop.py (original)
+++ hadoop/core/trunk/src/contrib/hod/hodlib/Hod/hadoop.py Wed Jul 23 23:41:39
2008
@@ -509,6 +509,8 @@
workerInfoMap = {}
workerInfoMap['HDFS UI'] = 'http://%s' % self.hdfsInfo
workerInfoMap['Mapred UI'] = 'http://%s' % self.mapredInfo
+ if mapredAddr.find(':') != -1:
+ workerInfoMap['Mapred RPC Port'] =
mapredAddr.split(':')[1]
ret = self.__nodePool.updateWorkerInfo(workerInfoMap,
self.jobId)
if ret != 0:
self.__log.warn('Could not update HDFS and Mapred
information.' \
Modified: hadoop/core/trunk/src/contrib/hod/hodlib/Hod/nodePool.py
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hod/hodlib/Hod/nodePool.py?rev=679286&r1=679285&r2=679286&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hod/hodlib/Hod/nodePool.py (original)
+++ hadoop/core/trunk/src/contrib/hod/hodlib/Hod/nodePool.py Wed Jul 23
23:41:39 2008
@@ -112,7 +112,7 @@
"""Check if job can run by looking at any user/job limits"""
raise NotImplementedError
- def updateWorkerInfo(self, workerInfoMap):
+ def updateWorkerInfo(self, workerInfoMap, jobId):
"""Update information about the workers started by this NodePool."""
raise NotImplementedError
