HADOOP-1879. Remove some unneeded casts. Contributed by Nilay Vaish.

git-svn-id: https://svn.apache.org/repos/asf/lucene/hadoop/trunk@575455 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -226,6 +226,8 @@ Trunk (unreleased changes)
     HADOOP-1592.  Log error messages to the client console when tasks
     fail.  (Amar Kamat via cutting)
 
+    HADOOP-1879.  Remove some unneeded casts.  (Nilay Vaish via cutting)
+
 
 Release 0.14.1 - 2007-09-04
 

src/java/org/apache/hadoop/dfs/DFSClient.java

@@ -685,7 +685,7 @@ class DFSClient implements FSConstants {
                               firstChunkOffset + " != " + chunkOffset);
       }
       
-      int chunkLen = (int) in.readInt();
+      int chunkLen = in.readInt();
       
       // Sanity check the lengths
       if ( chunkLen < 0 || chunkLen > bytesPerChecksum ||

src/java/org/apache/hadoop/dfs/DataNode.java

@@ -877,7 +877,7 @@ public class DataNode implements FSConstants, Runnable {
           // Read one data chunk in each loop.
           
           long offset = lastOffset + lastLen;
-          int len = (int) in.readInt();
+          int len = in.readInt();
           if ( len < 0 || len > bytesPerChecksum ) {
             LOG.warn( "Got wrong length during writeBlock(" +
                       block + ") from " + s.getRemoteSocketAddress() +

src/java/org/apache/hadoop/dfs/DatanodeInfo.java

@@ -308,7 +308,7 @@ public class DatanodeInfo extends DatanodeID implements Node {
     this.xceiverCount = in.readInt();
     this.location = Text.readString(in);
     this.hostName = Text.readString(in);
-    AdminStates newState = (AdminStates) WritableUtils.readEnum(in,
+    AdminStates newState = WritableUtils.readEnum(in,
                                                                 AdminStates.class);
     setAdminState(newState);
   }

src/java/org/apache/hadoop/dfs/FSDataset.java

@@ -558,7 +558,7 @@ class FSDataset implements FSConstants {
       //
       if (ongoingCreates.containsKey(b)) {
         // check how old is the temp file - wait 1 hour
-        File tmp = (File)ongoingCreates.get(b);
+        File tmp = ongoingCreates.get(b);
         if ((System.currentTimeMillis() - tmp.lastModified()) < 3600 * 1000) {
           throw new IOException("Block " + b +
                                 " has already been started (though not completed), and thus cannot be created.");

src/java/org/apache/hadoop/dfs/FSNamesystem.java

@@ -581,7 +581,7 @@ class FSNamesystem implements FSConstants {
     client = host2DataNodeMap.getDatanodeByHost(clientMachine);
     for (Iterator<LocatedBlock> it = blocks.getLocatedBlocks().iterator();
          it.hasNext();) {
-      LocatedBlock block = (LocatedBlock) it.next();
+      LocatedBlock block = it.next();
       clusterMap.pseudoSortByDistance(client, 
                                 (DatanodeDescriptor[])(block.getLocations()));
     }
@@ -1136,7 +1136,7 @@ class FSNamesystem implements FSConstants {
                 values.size() + " datanodes.");
     while (it.hasNext()) {
       Map.Entry<String,Collection<Block>> entry = it.next();
-      String storageId = (String) entry.getKey();
+      String storageId = entry.getKey();
       DatanodeDescriptor node = datanodeMap.get(storageId);
       Collection<Block> blklist = entry.getValue();
       if (blklist.size() > 0) {
@@ -2149,7 +2149,7 @@ class FSNamesystem implements FSConstants {
                                       +"ask "+nodeID.getName()+" to delete "+b.getBlockName());
       }
     }
-    return (Block[]) obsolete.toArray(new Block[obsolete.size()]);
+    return obsolete.toArray(new Block[obsolete.size()]);
   }
 
   /**
@@ -2841,8 +2841,7 @@ class FSNamesystem implements FSConstants {
           int i = 0;
           for (Iterator<Block> it = replicateBlocks.iterator(); it.hasNext(); i++) {
             Block block = it.next();
-            DatanodeDescriptor targets[] = 
-              (DatanodeDescriptor[]) replicateTargetSets.get(i);
+            DatanodeDescriptor targets[] = replicateTargetSets.get(i);
             int numCurrentReplica = numCurrentReplicas.get(i).liveReplicas();
             int numExpectedReplica = blocksMap.getINode(block).getReplication(); 
             if (numCurrentReplica + targets.length >= numExpectedReplica) {

src/java/org/apache/hadoop/filecache/DistributedCache.java

@@ -108,7 +108,7 @@ public class DistributedCache {
     throws IOException {
     String cacheId = makeRelative(cache, conf);
     synchronized (cachedArchives) {
-      CacheStatus lcacheStatus = (CacheStatus) cachedArchives.get(cacheId);
+      CacheStatus lcacheStatus = cachedArchives.get(cacheId);
       if (lcacheStatus == null)
         return;
       synchronized (lcacheStatus) {
@@ -124,7 +124,7 @@ public class DistributedCache {
     synchronized (cachedArchives) {
       for (Iterator it = cachedArchives.keySet().iterator(); it.hasNext();) {
         String cacheId = (String) it.next();
-        CacheStatus lcacheStatus = (CacheStatus) cachedArchives.get(cacheId);
+        CacheStatus lcacheStatus = cachedArchives.get(cacheId);
         synchronized (lcacheStatus) {
           if (lcacheStatus.refcount == 0) {
             // delete this cache entry

src/java/org/apache/hadoop/fs/FileSystem.java

@@ -531,7 +531,7 @@ public abstract class FileSystem extends Configured {
     for(int i=0; i<files.length; i++) {
       listPaths(results, files[i], filter);
     }
-    return (Path[]) results.toArray(new Path[results.size()]);
+    return results.toArray(new Path[results.size()]);
   }
     
   /**

src/java/org/apache/hadoop/fs/InMemoryFileSystem.java

@@ -194,7 +194,7 @@ public class InMemoryFileSystem extends ChecksumFileSystem {
         if (exists(f) && !overwrite) {
           throw new IOException("File already exists:"+f);
         }
-        FileAttributes fAttr =(FileAttributes) tempFileAttribs.remove(getPath(f));
+        FileAttributes fAttr = tempFileAttribs.remove(getPath(f));
         if (fAttr != null)
           return create(f, fAttr);
         return null;

src/java/org/apache/hadoop/io/IntWritable.java

@@ -51,7 +51,7 @@ public class IntWritable implements WritableComparable {
   }
 
   public int hashCode() {
-    return (int)value;
+    return value;
   }
 
   /** Compares two IntWritables. */

src/java/org/apache/hadoop/io/Text.java

@@ -522,17 +522,17 @@ public class Text implements WritableComparable {
     bytes.mark();
     byte b = bytes.get();
     bytes.reset();
-    int extraBytesToRead = bytesFromUTF8[(int)(b & 0xFF)];
+    int extraBytesToRead = bytesFromUTF8[(b & 0xFF)];
     if (extraBytesToRead < 0) return -1; // trailing byte!
     int ch = 0;
 
     switch (extraBytesToRead) {
-    case 5: ch += (int)(bytes.get() & 0xFF); ch <<= 6; /* remember, illegal UTF-8 */
-    case 4: ch += (int)(bytes.get() & 0xFF); ch <<= 6; /* remember, illegal UTF-8 */
-    case 3: ch += (int)(bytes.get() & 0xFF); ch <<= 6;
-    case 2: ch += (int)(bytes.get() & 0xFF); ch <<= 6;
-    case 1: ch += (int)(bytes.get() & 0xFF); ch <<= 6;
-    case 0: ch += (int)(bytes.get() & 0xFF);
+    case 5: ch += (bytes.get() & 0xFF); ch <<= 6; /* remember, illegal UTF-8 */
+    case 4: ch += (bytes.get() & 0xFF); ch <<= 6; /* remember, illegal UTF-8 */
+    case 3: ch += (bytes.get() & 0xFF); ch <<= 6;
+    case 2: ch += (bytes.get() & 0xFF); ch <<= 6;
+    case 1: ch += (bytes.get() & 0xFF); ch <<= 6;
+    case 0: ch += (bytes.get() & 0xFF);
     }
     ch -= offsetsFromUTF8[extraBytesToRead];
 

src/java/org/apache/hadoop/io/VIntWritable.java

@@ -55,7 +55,7 @@ public class VIntWritable implements WritableComparable {
   }
 
   public int hashCode() {
-    return (int)value;
+    return value;
   }
 
   /** Compares two VIntWritables. */

src/java/org/apache/hadoop/io/WritableUtils.java

@@ -394,7 +394,7 @@ public final class WritableUtils  {
     int total = 0;
     int cur = 0;
 
-    while ((total<len) && ((cur = (int) in.skipBytes(len-total)) > 0)) {
+    while ((total<len) && ((cur = in.skipBytes(len-total)) > 0)) {
         total += cur;
     }
 

src/java/org/apache/hadoop/ipc/Client.java

@@ -261,7 +261,7 @@ public class Client {
           if (LOG.isDebugEnabled())
             LOG.debug(getName() + " got value #" + id);
 
-          Call call = (Call)calls.remove(id);
+          Call call = calls.remove(id);
           boolean isError = in.readBoolean();     // read if error
           if (isError) {
             call.setResult(null, WritableUtils.readString(in),
@@ -515,7 +515,7 @@ public class Client {
     throws IOException {
     Connection connection;
     synchronized (connections) {
-      connection = (Connection)connections.get(address);
+      connection = connections.get(address);
       if (connection == null) {
         connection = new Connection(address);
         connections.put(address, connection);

src/java/org/apache/hadoop/ipc/Server.java

@@ -252,7 +252,7 @@ public abstract class Server {
           Connection c;
           synchronized (connectionList) {
             try {
-              c = (Connection)connectionList.get(i);
+              c = connectionList.get(i);
             } catch (Exception e) {return;}
           }
           if (c.timedOut(currentTime)) {
@@ -526,7 +526,7 @@ public abstract class Server {
       Call call = new Call(id, param, this);
       synchronized (callQueue) {
         if (callQueue.size() >= maxQueueSize) {
-          Call oldCall = (Call) callQueue.removeFirst();
+          Call oldCall = callQueue.removeFirst();
           LOG.warn("Call queue overflow discarding oldest call " + oldCall);
         }
         callQueue.addLast(call);              // queue the call
@@ -570,7 +570,7 @@ public abstract class Server {
               callQueue.wait(timeout);
             }
             if (!running) break;
-            call = (Call)callQueue.removeFirst(); // pop the queue
+            call = callQueue.removeFirst(); // pop the queue
           }
 
           // throw the message away if it is too old

src/java/org/apache/hadoop/mapred/DefaultJobHistoryParser.java

@@ -165,7 +165,7 @@ public class DefaultJobHistoryParser {
         currentTracker = values.get(Keys.START_TIME);
         jobTrackerToJobs.put(currentTracker, activeJobs);
       } else if (recType.equals(JobHistory.RecordTypes.Job)) {
-        String jobId = (String) values.get(Keys.JOBID);
+        String jobId = values.get(Keys.JOBID);
         JobHistory.JobInfo job = activeJobs.get(jobId);
         if (null == job) {
           job = new JobHistory.JobInfo(jobId);

src/java/org/apache/hadoop/mapred/FileInputFormat.java

@@ -95,7 +95,7 @@ public abstract class FileInputFormat<K extends WritableComparable,
       }
     }
 
-    return (Path[])result.toArray(new Path[result.size()]);
+    return result.toArray(new Path[result.size()]);
   }
 
   public void validateInput(JobConf job) throws IOException {

src/java/org/apache/hadoop/mapred/JobHistory.java

@@ -369,7 +369,7 @@ public class JobHistory {
         }
         
         String logFileName =  JOBTRACKER_START_TIME + "_" + jobId; 
-        PrintWriter writer = (PrintWriter)openJobs.get(logFileName); 
+        PrintWriter writer = openJobs.get(logFileName); 
         
         if (null != writer){
           JobHistory.log(writer, RecordTypes.Job, 
@@ -430,7 +430,7 @@ public class JobHistory {
                                        String.valueOf(finishedReduces)}); 
         }
         String logFileName =  JOBTRACKER_START_TIME + "_" + jobid; 
-        PrintWriter writer = (PrintWriter)openJobs.get(logFileName); 
+        PrintWriter writer = openJobs.get(logFileName); 
         if (null != writer){
           JobHistory.log(writer, RecordTypes.Job,
                          new Enum[] {Keys.JOBID, Keys.FINISH_TIME, Keys.JOB_STATUS, Keys.FINISHED_MAPS, Keys.FINISHED_REDUCES },
@@ -460,7 +460,7 @@ public class JobHistory {
     public static void logStarted(String jobId, String taskId, String taskType, 
                                   long startTime){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId); 
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId); 
         if (null != writer){
           JobHistory.log(writer, RecordTypes.Task, new Enum[]{Keys.TASKID, Keys.TASK_TYPE , Keys.START_TIME}, 
                          new String[]{taskId, taskType, String.valueOf(startTime)});
@@ -477,7 +477,7 @@ public class JobHistory {
     public static void logFinished(String jobId, String taskId, String taskType, 
                                    long finishTime){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId); 
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId); 
         if (null != writer){
           JobHistory.log(writer, RecordTypes.Task, new Enum[]{Keys.TASKID, Keys.TASK_TYPE, 
                                                               Keys.TASK_STATUS, Keys.FINISH_TIME}, 
@@ -495,7 +495,7 @@ public class JobHistory {
      */
     public static void logFailed(String jobId, String taskId, String taskType, long time, String error){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId); 
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId); 
         if (null != writer){
           JobHistory.log(writer, RecordTypes.Task, new Enum[]{Keys.TASKID, Keys.TASK_TYPE, 
                                                               Keys.TASK_STATUS, Keys.FINISH_TIME, Keys.ERROR}, 
@@ -531,7 +531,7 @@ public class JobHistory {
      */
     public static void logStarted(String jobId, String taskId, String taskAttemptId, long startTime, String hostName){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.MapAttempt, 
                          new Enum[]{ Keys.TASK_TYPE, Keys.TASKID, 
@@ -551,7 +551,7 @@ public class JobHistory {
      */
     public static void logFinished(String jobId, String taskId, String taskAttemptId, long finishTime, String hostName){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.MapAttempt, 
                          new Enum[]{ Keys.TASK_TYPE, Keys.TASKID, Keys.TASK_ATTEMPT_ID, Keys.TASK_STATUS, 
@@ -573,7 +573,7 @@ public class JobHistory {
     public static void logFailed(String jobId, String taskId, String taskAttemptId, 
                                  long timestamp, String hostName, String error){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.MapAttempt, 
                          new Enum[]{Keys.TASK_TYPE, Keys.TASKID, Keys.TASK_ATTEMPT_ID, Keys.TASK_STATUS, 
@@ -595,7 +595,7 @@ public class JobHistory {
     public static void logKilled(String jobId, String taskId, String taskAttemptId, 
                                  long timestamp, String hostName, String error){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.MapAttempt, 
                          new Enum[]{Keys.TASK_TYPE, Keys.TASKID, Keys.TASK_ATTEMPT_ID, Keys.TASK_STATUS, 
@@ -622,7 +622,7 @@ public class JobHistory {
     public static void logStarted(String jobId, String taskId, String taskAttemptId, 
                                   long startTime, String hostName){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.ReduceAttempt, 
                          new Enum[]{  Keys.TASK_TYPE, Keys.TASKID, 
@@ -645,7 +645,7 @@ public class JobHistory {
     public static void logFinished(String jobId, String taskId, String taskAttemptId, 
                                    long shuffleFinished, long sortFinished, long finishTime, String hostName){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.ReduceAttempt, 
                          new Enum[]{ Keys.TASK_TYPE, Keys.TASKID, Keys.TASK_ATTEMPT_ID, Keys.TASK_STATUS, 
@@ -668,7 +668,7 @@ public class JobHistory {
     public static void logFailed(String jobId, String taskId, String taskAttemptId, long timestamp, 
                                  String hostName, String error){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.ReduceAttempt, 
                          new Enum[]{  Keys.TASK_TYPE, Keys.TASKID, Keys.TASK_ATTEMPT_ID, Keys.TASK_STATUS, 
@@ -690,7 +690,7 @@ public class JobHistory {
     public static void logKilled(String jobId, String taskId, String taskAttemptId, long timestamp, 
                                  String hostName, String error){
       if (!disableHistory){
-        PrintWriter writer = (PrintWriter)openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
+        PrintWriter writer = openJobs.get(JOBTRACKER_START_TIME + "_" + jobId);
         if (null != writer){
           JobHistory.log(writer, RecordTypes.ReduceAttempt, 
                          new Enum[]{  Keys.TASK_TYPE, Keys.TASKID, Keys.TASK_ATTEMPT_ID, Keys.TASK_STATUS, 

src/java/org/apache/hadoop/mapred/JobInProgress.java

@@ -131,7 +131,7 @@ class JobInProgress {
     this.jobtracker = jobtracker;
     this.status = new JobStatus(jobid, 0.0f, 0.0f, JobStatus.PREP);
     this.startTime = System.currentTimeMillis();
-    this.localFs = (LocalFileSystem)FileSystem.getLocal(default_conf);
+    this.localFs = FileSystem.getLocal(default_conf);
 
     JobConf default_job_conf = new JobConf(default_conf);
     this.localJobFile = default_job_conf.getLocalPath(JobTracker.SUBDIR 
@@ -1142,8 +1142,7 @@ class JobInProgress {
     if (taskCompletionEvents.size() > fromEventId) {
       int actualMax = Math.min(maxEvents, 
                                (taskCompletionEvents.size() - fromEventId));
-      events = (TaskCompletionEvent[])taskCompletionEvents.subList(
-                                                                   fromEventId, actualMax + fromEventId).toArray(events);        
+      events = taskCompletionEvents.subList(fromEventId, actualMax + fromEventId).toArray(events);        
     }
     return events; 
   }

src/java/org/apache/hadoop/mapred/JobTracker.java

@@ -650,7 +650,7 @@ public class JobTracker implements MRConstants, InterTrackerProtocol, JobSubmiss
       Properties p = System.getProperties();
       for (Iterator it = p.keySet().iterator(); it.hasNext();) {
         String key = (String) it.next();
-        String val = (String) p.getProperty(key);
+        String val = p.getProperty(key);
         LOG.debug("Property '" + key + "' is " + val);
       }
     }
@@ -1694,8 +1694,7 @@ public class JobTracker implements MRConstants, InterTrackerProtocol, JobSubmiss
    */
   private TaskInProgress getTip(String jobid, String tipid) {
     JobInProgress job = jobs.get(jobid);
-    return (job == null ? null 
-            : (TaskInProgress) job.getTaskInProgress(tipid));
+    return (job == null ? null : job.getTaskInProgress(tipid));
   }
     
   /** Mark a Task to be killed */

src/java/org/apache/hadoop/mapred/MergeSorter.java

@@ -40,7 +40,7 @@ implements Comparator<IntWritable> {
     MergeSort m = new MergeSort(this);
     int count = super.count;
     if (count == 0) return null;
-    int [] pointers = (int[])super.pointers;
+    int [] pointers = super.pointers;
     int [] pointersCopy = new int[count];
     System.arraycopy(pointers, 0, pointersCopy, 0, count);
     m.mergeSort(pointers, pointersCopy, 0, count);

src/java/org/apache/hadoop/mapred/TaskTracker.java

@@ -549,8 +549,7 @@ public class TaskTracker
           int actualMax = Math.min(max, (allMapEvents.size() - fromId));
           List <TaskCompletionEvent> eventSublist = 
             allMapEvents.subList(fromId, actualMax + fromId);
-          mapEvents = 
-            (TaskCompletionEvent[])eventSublist.toArray(mapEvents);
+          mapEvents = eventSublist.toArray(mapEvents);
         }
       }
       return mapEvents;
@@ -1580,9 +1579,9 @@ public class TaskTracker
    * Called upon startup by the child process, to fetch Task data.
    */
   public synchronized Task getTask(String taskid) throws IOException {
-    TaskInProgress tip = (TaskInProgress) tasks.get(taskid);
+    TaskInProgress tip = tasks.get(taskid);
     if (tip != null) {
-      return (Task) tip.getTask();
+      return tip.getTask();
     } else {
       return null;
     }
@@ -1594,7 +1593,7 @@ public class TaskTracker
   public synchronized boolean statusUpdate(String taskid, 
                                               TaskStatus taskStatus) 
   throws IOException {
-    TaskInProgress tip = (TaskInProgress) tasks.get(taskid);
+    TaskInProgress tip = tasks.get(taskid);
     if (tip != null) {
       tip.reportProgress(taskStatus);
       return true;
@@ -1609,7 +1608,7 @@ public class TaskTracker
    * diagnostic info
    */
   public synchronized void reportDiagnosticInfo(String taskid, String info) throws IOException {
-    TaskInProgress tip = (TaskInProgress) tasks.get(taskid);
+    TaskInProgress tip = tasks.get(taskid);
     if (tip != null) {
       tip.reportDiagnosticInfo(info);
     } else {
@@ -1626,7 +1625,7 @@ public class TaskTracker
    * The task is done.
    */
   public synchronized void done(String taskid) throws IOException {
-    TaskInProgress tip = (TaskInProgress) tasks.get(taskid);
+    TaskInProgress tip = tasks.get(taskid);
     if (tip != null) {
       tip.reportDone();
     } else {
@@ -1685,7 +1684,7 @@ public class TaskTracker
   void reportTaskFinished(String taskid) {
     TaskInProgress tip;
     synchronized (this) {
-      tip = (TaskInProgress) tasks.get(taskid);
+      tip = tasks.get(taskid);
     }
     if (tip != null) {
       tip.taskFinished();
@@ -1703,7 +1702,7 @@ public class TaskTracker
    */
   public synchronized void mapOutputLost(String taskid,
                                          String errorMsg) throws IOException {
-    TaskInProgress tip = (TaskInProgress) tasks.get(taskid);
+    TaskInProgress tip = tasks.get(taskid);
     if (tip != null) {
       tip.mapOutputLost(errorMsg);
     } else {

src/java/org/apache/hadoop/metrics/ganglia/GangliaContext.java

@@ -119,7 +119,7 @@ public class GangliaContext extends AbstractMetricsContext {
     // emit each metric in turn
     for (String metricName : outRec.getMetricNames()) {
       Object metric = outRec.getMetric(metricName);
-      String type = (String) typeTable.get(metric.getClass());
+      String type = typeTable.get(metric.getClass());
       emitMetric(metricName, type, metric.toString());
     }
         
@@ -151,7 +151,7 @@ public class GangliaContext extends AbstractMetricsContext {
   }
     
   private String getUnits(String metricName) {
-    String result = (String) unitsTable.get(metricName);
+    String result = unitsTable.get(metricName);
     if (result == null) {
       result = DEFAULT_UNITS;
     }
@@ -159,7 +159,7 @@ public class GangliaContext extends AbstractMetricsContext {
   }
     
   private int getSlope(String metricName) {
-    String slopeString = (String) slopeTable.get(metricName);
+    String slopeString = slopeTable.get(metricName);
     if (slopeString == null) {
       slopeString = DEFAULT_SLOPE; 
     }
@@ -167,7 +167,7 @@ public class GangliaContext extends AbstractMetricsContext {
   }
     
   private int getTmax(String metricName) {
-    String tmaxString = (String) tmaxTable.get(metricName);
+    String tmaxString = tmaxTable.get(metricName);
     if (tmaxString == null) {
       return DEFAULT_TMAX;
     }
@@ -177,7 +177,7 @@ public class GangliaContext extends AbstractMetricsContext {
   }
     
   private int getDmax(String metricName) {
-    String dmaxString = (String) dmaxTable.get(metricName);
+    String dmaxString = dmaxTable.get(metricName);
     if (dmaxString == null) {
       return DEFAULT_DMAX;
     }

src/java/org/apache/hadoop/metrics/spi/OutputRecord.java

@@ -66,7 +66,7 @@ public class OutputRecord {
    * Returns the metric object which can be a Float, Integer, Short or Byte.
    */
   public Number getMetric(String name) {
-    return (Number) metricMap.get(name);
+    return metricMap.get(name);
   }
     
 }

src/java/org/apache/hadoop/net/DNS.java

@@ -97,7 +97,7 @@ public class DNS {
         Enumeration e = netIF.getInetAddresses();
         while (e.hasMoreElements())
           ips.add(((InetAddress) e.nextElement()).getHostAddress());
-        return (String[]) ips.toArray(new String[] {});
+        return ips.toArray(new String[] {});
       }
     } catch (SocketException e) {
       return new String[] { InetAddress.getLocalHost().getHostAddress() };
@@ -146,7 +146,7 @@ public class DNS {
     if (hosts.size() == 0)
       return new String[] { InetAddress.getLocalHost().getCanonicalHostName() };
     else
-      return (String[]) hosts.toArray(new String[] {});
+      return hosts.toArray(new String[] {});
   }
 
   /**

src/java/org/apache/hadoop/record/compiler/generated/Rcc.java

@@ -89,7 +89,7 @@ public class Rcc implements RccConstants {
         } catch (IOException e) {
         }
       } catch (FileNotFoundException e) {
-        System.err.println("File " + (String) recFiles.get(i) +
+        System.err.println("File " + recFiles.get(i) +
                            " Not found.");
         return 1;
       }
@@ -486,7 +486,7 @@ public class Rcc implements RccConstants {
       return (jj_ntk = jj_nt.kind);
   }
 
-  private java.util.Vector jj_expentries = new java.util.Vector();
+  private java.util.Vector<int[]> jj_expentries = new java.util.Vector<int[]>();
   private int[] jj_expentry;
   private int jj_kind = -1;
 
@@ -521,7 +521,7 @@ public class Rcc implements RccConstants {
     }
     int[][] exptokseq = new int[jj_expentries.size()][];
     for (int i = 0; i < jj_expentries.size(); i++) {
-      exptokseq[i] = (int[])jj_expentries.elementAt(i);
+      exptokseq[i] = jj_expentries.elementAt(i);
     }
     return new ParseException(token, exptokseq, tokenImage);
   }

src/java/org/apache/hadoop/util/RunJar.java

@@ -149,7 +149,7 @@ public class RunJar {
     Method main = mainClass.getMethod("main", new Class[] {
       Array.newInstance(String.class, 0).getClass()
     });
-    String[] newArgs = (String[])Arrays.asList(args)
+    String[] newArgs = Arrays.asList(args)
       .subList(firstArg, args.length).toArray(new String[0]);
     try {
       main.invoke(null, new Object[] { newArgs });

src/java/org/apache/hadoop/util/StringUtils.java

@@ -267,7 +267,7 @@ public class StringUtils {
     while (tokenizer.hasMoreTokens()) {
       values.add(tokenizer.nextToken());
     }
-    return (String[])values.toArray(new String[values.size()]);
+    return values.toArray(new String[values.size()]);
   }
 
   /**