diff --git a/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java b/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java index 9807383ec3bc3083655080378060d5b154f56de6..8a05628c8fcf2f10ac5aa2b8e54f1ca78dd83caf 100644 --- a/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java +++ b/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java @@ -68,7 +68,7 @@ public class YarnShuffleService extends AuxiliaryService { private static final String SPARK_AUTHENTICATE_KEY = "spark.authenticate"; private static final boolean DEFAULT_SPARK_AUTHENTICATE = false; - private static final String RECOVERY_FILE_NAME = "registeredExecutor.ldb"; + private static final String RECOVERY_FILE_NAME = "registeredExecutors.ldb"; // An entity that manages the shuffle secret per application // This is used only if authentication is enabled