Browse Source

Fix a bug in HADOOP-347.

git-svn-id: https://svn.apache.org/repos/asf/lucene/hadoop/trunk@423856 13f79535-47bb-0310-9956-ffa450edef68
Doug Cutting 19 năm trước cách đây
mục cha
commit
33fad65c19
1 tập tin đã thay đổi với 6 bổ sung5 xóa
  1. 6 5
      src/java/org/apache/hadoop/dfs/FSNamesystem.java

+ 6 - 5
src/java/org/apache/hadoop/dfs/FSNamesystem.java

@@ -1947,11 +1947,12 @@ class FSNamesystem implements FSConstants {
     public String randomDataNode() {
       int size = datanodeMap.size();
       int index = 0;
-      if (size != 0)
-        index = r.nextInt() % size;
-      DatanodeInfo d = getDatanodeByIndex(index);
-      if (d != null) {
-        return d.getHost();
+      if (size != 0) {
+        index = r.nextInt(size);
+        DatanodeInfo d = getDatanodeByIndex(index);
+        if (d != null) {
+          return d.getHost();
+        }
       }
       return null;
     }