InProgressList not to be purged on the stream close.

saxenapranav · saxenapranav · commit 54e706a84415 · 2022-11-30T19:07:57.000-08:00
diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/ReadBufferManager.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/ReadBufferManager.java
@@ -544,7 +544,6 @@ public synchronized void purgeBuffersForStream(AbfsInputStream stream) {
     LOGGER.debug("Purging stale buffers for AbfsInputStream {} ", stream);
     readAheadQueue.removeIf(readBuffer -> readBuffer.getStream() == stream);
     purgeList(stream, completedReadList);
-    purgeList(stream, inProgressList);
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -544,7 +544,6 @@ public synchronized void purgeBuffersForStream(AbfsInputStream stream) {`
`544`	`544`	`LOGGER.debug("Purging stale buffers for AbfsInputStream {} ", stream);`
`545`	`545`	`readAheadQueue.removeIf(readBuffer -> readBuffer.getStream() == stream);`
`546`	`546`	`purgeList(stream, completedReadList);`
`547`		`- purgeList(stream, inProgressList);`
`548`	`547`	`}`
`549`	`548`
`550`	`549`	`/**`