Fixing issues related to sleep

Ritesh Garg · Ritesh Garg · commit 01d950accaaf · 2024-03-15T15:13:44.000-07:00
diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DataStreamer.java
@@ -1242,7 +1242,7 @@ private boolean processDatanodeError() throws IOException {
       streamerClosed = true;
       return false;
     }
-    boolean doSleep = false;
+
     setupPipelineForAppendOrRecovery();
 
     if (!streamerClosed && dfsClient.clientRunning) {
@@ -1277,7 +1277,7 @@ private boolean processDatanodeError() throws IOException {
       }
     }
 
-    return doSleep;
+    return false;
   }
 
   void setHflush() {

Original file line number	Diff line number	Diff line change
`@@ -1242,7 +1242,7 @@ private boolean processDatanodeError() throws IOException {`
`1242`	`1242`	`streamerClosed = true;`
`1243`	`1243`	`return false;`
`1244`	`1244`	`}`
`1245`		`- boolean doSleep = false;`
	`1245`	`+`
`1246`	`1246`	`setupPipelineForAppendOrRecovery();`
`1247`	`1247`
`1248`	`1248`	`if (!streamerClosed && dfsClient.clientRunning) {`
`@@ -1277,7 +1277,7 @@ private boolean processDatanodeError() throws IOException {`
`1277`	`1277`	`}`
`1278`	`1278`	`}`
`1279`	`1279`
`1280`		`- return doSleep;`
	`1280`	`+ return false;`
`1281`	`1281`	`}`
`1282`	`1282`
`1283`	`1283`	`void setHflush() {`