diff --git a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java index b74830101ce6d..9483e48ca446c 100644 --- a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java +++ b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java @@ -417,9 +417,7 @@ void removeAppAttemptPathInfoFromDB(String appId, int attemptId) { if (db != null) { try { byte[] key = getDbAppAttemptPathsKey(appAttemptId); - if (db.get(key) != null) { - db.delete(key); - } + db.delete(key); } catch (Exception e) { logger.error("Failed to remove the application attempt {} local path in DB", appAttemptId, e);