Skip to content

Commit 2b7aeaa

Browse files
committed
HDFS-17529. Minor change
1 parent bd90510 commit 2b7aeaa

File tree

1 file changed

+1
-5
lines changed
  • hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/store

1 file changed

+1
-5
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/store/CachedRecordStore.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,6 @@ private boolean isUpdateTime() {
174174
public void overrideExpiredRecords(QueryResult<R> query) throws IOException {
175175
List<R> commitRecords = new ArrayList<>();
176176
List<R> toDeleteRecords = new ArrayList<>();
177-
List<R> deletedRecords = new ArrayList<>();
178177
List<R> newRecords = query.getRecords();
179178
long currentDriverTime = query.getTimestamp();
180179
if (newRecords == null || currentDriverTime <= 0) {
@@ -198,13 +197,10 @@ public void overrideExpiredRecords(QueryResult<R> query) throws IOException {
198197
if (!toDeleteRecords.isEmpty()) {
199198
for (Map.Entry<R, Boolean> entry : getDriver().removeMultiple(toDeleteRecords).entrySet()) {
200199
if (entry.getValue()) {
201-
deletedRecords.add(entry.getKey());
200+
newRecords.remove(entry.getKey());
202201
}
203202
}
204203
}
205-
if (!deletedRecords.isEmpty()) {
206-
newRecords.removeAll(deletedRecords);
207-
}
208204
}
209205

210206
/**

0 commit comments

Comments
 (0)