Ver Fonte

HADOOP-1170. Improve datanode performance by removing device checks from common operations. Contributed by Igor Bolotin.

git-svn-id: https://svn.apache.org/repos/asf/lucene/hadoop/trunk@524271 13f79535-47bb-0310-9956-ffa450edef68
Doug Cutting há 18 anos atrás
pai
commit
abbbfde688
2 ficheiros alterados com 3 adições e 9 exclusões
  1. 3 0
      CHANGES.txt
  2. 0 9
      src/java/org/apache/hadoop/dfs/DataNode.java

+ 3 - 0
CHANGES.txt

@@ -79,6 +79,9 @@ Trunk (unreleased changes)
 24. HADOOP-672.  Improve help for fs shell commands.
     (Dhruba Borthakur via cutting)
 
+25. HADOOP-1170.  Improve datanode performance by removing device
+    checks from common operations.  (Igor Bolotin via cutting)
+
 
 Release 0.12.3 (not yet released)
 

+ 0 - 9
src/java/org/apache/hadoop/dfs/DataNode.java

@@ -419,7 +419,6 @@ public class DataNode implements FSConstants, Runnable {
             lastHeartbeat = now;
 
             if( cmd != null ) {
-              data.checkDataDir();
               switch( cmd.action ) {
               case DNA_TRANSFER:
                 //
@@ -454,9 +453,6 @@ public class DataNode implements FSConstants, Runnable {
             
           // send block report
           if (now - lastBlockReport > blockReportInterval) {
-            // before send block report, check if data directory is healthy
-            data.checkDataDir();
-                
             //
             // Send latest blockinfo report if timer has expired.
             // Get back a list of local block(s) that are obsolete
@@ -558,15 +554,10 @@ public class DataNode implements FSConstants, Runnable {
                 while (shouldRun) {
                     Socket s = ss.accept();
                     //s.setSoTimeout(READ_TIMEOUT);
-                    data.checkDataDir();
                     xceiverCount.incr();
                     new Daemon(new DataXceiver(s)).start();
                 }
                 ss.close();
-            } catch (DiskErrorException de ) {
-                String errMsgr = de.getMessage();
-                LOG.warn("Exiting DataXceiveServer due to "+ errMsgr );
-                handleDiskError(errMsgr);
             } catch (IOException ie) {
                 LOG.info("Exiting DataXceiveServer due to " + ie.toString());
             }