|
@@ -1068,7 +1068,7 @@ class BPServiceActor implements Runnable {
|
|
|
volatile long nextHeartbeatTime = monotonicNow();
|
|
|
|
|
|
@VisibleForTesting
|
|
|
- volatile long nextLifelineTime = monotonicNow();
|
|
|
+ volatile long nextLifelineTime;
|
|
|
|
|
|
@VisibleForTesting
|
|
|
volatile long lastBlockReportTime = monotonicNow();
|
|
@@ -1091,6 +1091,7 @@ class BPServiceActor implements Runnable {
|
|
|
this.heartbeatIntervalMs = heartbeatIntervalMs;
|
|
|
this.lifelineIntervalMs = lifelineIntervalMs;
|
|
|
this.blockReportIntervalMs = blockReportIntervalMs;
|
|
|
+ scheduleNextLifeline(nextHeartbeatTime);
|
|
|
}
|
|
|
|
|
|
// This is useful to make sure NN gets Heartbeat before Blockreport
|