big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-16305.Record the remote NameNode address when the rolling log is triggered. (#3629)

Browse Source
This commit is contained in:
jianghuazhu 2021-11-12 09:52:02 +08:00 committed by GitHub
parent 1c1cf64616
commit 3d692c0936
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/EditLogTailer.java
View File

@ -413,6 +413,8 @@ Callable<Void> getNameNodeProxy() {
return new MultipleNameNodeProxy<Void>() { return new MultipleNameNodeProxy<Void>() {
@Override @Override
protected Void doWork() throws IOException { protected Void doWork() throws IOException {
LOG.info("Triggering log rolling to the remote NameNode, " +
"active NameNode = {}", currentNN.getIpcAddress());
cachedActiveProxy.rollEditLog(); cachedActiveProxy.rollEditLog();
return null; return null;
} }
@ -424,7 +426,6 @@ protected Void doWork() throws IOException {
*/ */
@VisibleForTesting @VisibleForTesting
void triggerActiveLogRoll() { void triggerActiveLogRoll() {
LOG.info("Triggering log roll on remote NameNode");
Future<Void> future = null; Future<Void> future = null;
try { try {
future = rollEditsRpcExecutor.submit(getNameNodeProxy()); future = rollEditsRpcExecutor.submit(getNameNodeProxy());