File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
network/shuffle/src/main/java/org/apache/spark/network/shuffle Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change 3737import org .apache .spark .network .buffer .ManagedBuffer ;
3838import org .apache .spark .network .shuffle .protocol .ExecutorShuffleInfo ;
3939import org .apache .spark .network .util .JavaUtils ;
40+ import org .apache .spark .network .util .NettyUtils ;
4041import org .apache .spark .network .util .TransportConf ;
4142
4243/**
4950 * the Executor's memory, unlike the IndexShuffleBlockManager.
5051 */
5152public class ExternalShuffleBlockManager {
52- private final Logger logger = LoggerFactory .getLogger (ExternalShuffleBlockManager .class );
53+ private static final Logger logger = LoggerFactory .getLogger (ExternalShuffleBlockManager .class );
5354
5455 // Map containing all registered executors' metadata.
5556 private final ConcurrentMap <AppExecId , ExecutorShuffleInfo > executors ;
@@ -60,8 +61,9 @@ public class ExternalShuffleBlockManager {
6061 private final TransportConf conf ;
6162
6263 public ExternalShuffleBlockManager (TransportConf conf ) {
63- // TODO: Give this thread a name.
64- this (conf , Executors .newSingleThreadExecutor ());
64+ this (conf , Executors .newSingleThreadExecutor (
65+ // Add `spark` prefix because it will run in NM in Yarn mode.
66+ NettyUtils .createThreadFactory ("spark-shuffle-directory-cleaner" )));
6567 }
6668
6769 // Allows tests to have more control over when directories are cleaned up.
You can’t perform that action at this time.
0 commit comments