From c7330d671cb4594ee98aa256ace1b89b8b27da0a Mon Sep 17 00:00:00 2001 From: yangjie01 Date: Fri, 5 Aug 2022 13:54:40 +0800 Subject: [PATCH] remove --- .../apache/spark/network/shuffle/RemoteBlockPushResolver.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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 677adc76bffc5..9aeb7318492a2 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);