fix tests

Author: xiezhineng

hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java

@@ -4387,4 +4387,11 @@ boolean isSlownode() {
   public BlockPoolManager getBlockPoolManager() {
     return blockPoolManager;
   }
+
+  @VisibleForTesting
+  public void closeDataXceiverServer() {
+    if (xserver != null) {
+      xserver.closeAllPeers();
+    }
+  }
 }

hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSStripedInputStreamWithTimeout.java

@@ -173,7 +173,10 @@ private  void testReadFileWithAttempt(int attempt) throws Exception {
       in.seek(readTotal);
       int nread = in.read(buf, 0, bufLen);
       // Simulated time-consuming processing operations, such as UDF.
-      Thread.sleep(10000);
+      // And datanodes close connect because of socket timeout.
+      cluster.dataNodes.forEach(dn -> {
+          dn.getDatanode().closeDataXceiverServer();
+      });
       in.seek(nread);
       // StripeRange 6MB
       bufLen = 1024 * 1024 * 6;