linyiqun commented on a change in pull request #2737:
URL: https://github.com/apache/hadoop/pull/2737#discussion_r615246158
##########
File path:
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSEditLogAsync.java
##########
@@ -67,6 +77,12 @@
DFS_NAMENODE_EDITS_ASYNC_LOGGING_PENDING_QUEUE_SIZE_DEFAULT);
editPendingQ = new ArrayBlockingQueue<>(editPendingQSize);
+
+ int logSyncNotifyExecutorSize = conf.getInt(
+ DFSConfigKeys.DFS_NAMENODE_EDITS_ASYNC_LOGSYNCNOTIFY_EXECUTOR_SIZE,
+ DFSConfigKeys.
+ DFS_NAMENODE_EDITS_ASYNC_LOGSYNCNOTIFY_EXECUTOR_SIZE_DEFAULT);
+ logSyncNotifyExecutor =
Executors.newFixedThreadPool(logSyncNotifyExecutorSize);
Review comment:
I still think that we would be better to shutdown logSyncNotifyExecutor
in close method and re-initialize logSyncNotifyExecutor in
FSEditLogAsync#openForWrite function. Every time NN does the failover, it will
invoke startActiveServices method and FSEditLogAsync#openForWrite will be
executed. Related code:
[FSNamesystem.java#L1373](https://github.com/apache/hadoop/blob/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java#L1373)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
