Skip to content

Commit 873189a

Browse files
committed
seperate status after master initialized
1 parent a6508ae commit 873189a

File tree

1 file changed

+7
-6
lines changed
  • hbase-server/src/main/java/org/apache/hadoop/hbase/master

1 file changed

+7
-6
lines changed

hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1201,7 +1201,8 @@ private void finishActiveMasterInitialization(TaskGroup startupTaskGroup)
12011201
// Set master as 'initialized'.
12021202
setInitialized(true);
12031203
startupTaskGroup.markComplete("Initialization successful");
1204-
MonitoredTask afterInitialized = startupTaskGroup.addTask("Progress after master initialized");
1204+
MonitoredTask status =
1205+
TaskMonitor.get().createStatus("Progress after master initialized", false, true);
12051206

12061207
if (tableFamilyDesc == null && replBarrierFamilyDesc == null) {
12071208
// create missing CFs in meta table after master is set to 'initialized'.
@@ -1232,7 +1233,7 @@ private void finishActiveMasterInitialization(TaskGroup startupTaskGroup)
12321233
}
12331234

12341235
assignmentManager.checkIfShouldMoveSystemRegionAsync();
1235-
afterInitialized.setStatus("Starting quota manager");
1236+
status.setStatus("Starting quota manager");
12361237
initQuotaManager();
12371238
if (QuotaUtil.isQuotaEnabled(conf)) {
12381239
// Create the quota snapshot notifier
@@ -1255,13 +1256,13 @@ private void finishActiveMasterInitialization(TaskGroup startupTaskGroup)
12551256
this.serverManager.clearDeadServersWithSameHostNameAndPortOfOnlineServer();
12561257

12571258
// Check and set the znode ACLs if needed in case we are overtaking a non-secure configuration
1258-
afterInitialized.setStatus("Checking ZNode ACLs");
1259+
status.setStatus("Checking ZNode ACLs");
12591260
zooKeeper.checkAndSetZNodeAcls();
12601261

1261-
afterInitialized.setStatus("Initializing MOB Cleaner");
1262+
status.setStatus("Initializing MOB Cleaner");
12621263
initMobCleaner();
12631264

1264-
afterInitialized.setStatus("Calling postStartMaster coprocessors");
1265+
status.setStatus("Calling postStartMaster coprocessors");
12651266
if (this.cpHost != null) {
12661267
// don't let cp initialization errors kill the master
12671268
try {
@@ -1286,7 +1287,7 @@ private void finishActiveMasterInitialization(TaskGroup startupTaskGroup)
12861287

12871288
this.rollingUpgradeChore = new RollingUpgradeChore(this);
12881289
getChoreService().scheduleChore(rollingUpgradeChore);
1289-
afterInitialized.markComplete("Progress after master initialized complete");
1290+
status.markComplete("Progress after master initialized complete");
12901291
}
12911292

12921293
private void createMissingCFsInMetaDuringUpgrade(TableDescriptor metaDescriptor)

0 commit comments

Comments
 (0)