ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[SPARK-14963][MINOR][YARN] Fix typo in YarnShuffleService recovery file name

Browse source 
## What changes were proposed in this pull request?

Due to the changes of [SPARK-14963](https://issues.apache.org/jira/browse/SPARK-14963), external shuffle recovery file name is changed mistakenly, so here change it back to the previous file name.

This only affects the master branch, branch-2.0 is correct [here](https://github.com/apache/spark/blob/branch-2.0/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java#L195).

## How was this patch tested?

N/A

Author: jerryshao <sshao@hortonworks.com>

Closes #14197 from jerryshao/fix-typo-file-name.
This commit is contained in:
jerryshao 2016-07-14 08:31:04 -05:00 committed by Tom Graves
parent e3f8a03367
commit c4bc2ed844
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java
View file

@ -68,7 +68,7 @@ public class YarnShuffleService extends AuxiliaryService {
private static final String SPARK_AUTHENTICATE_KEY = "spark.authenticate"; private static final String SPARK_AUTHENTICATE_KEY = "spark.authenticate";
private static final boolean DEFAULT_SPARK_AUTHENTICATE = false; 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 // An entity that manages the shuffle secret per application
// This is used only if authentication is enabled // This is used only if authentication is enabled