Revert "HDFS-16426. Fix nextBlockReportTime when trigger full block report force (#3887)"
This reverts commit 96dd426229
.
This commit is contained in:
parent
96dd426229
commit
53c4d89250
|
@ -136,23 +136,6 @@ public class TestBpServiceActorScheduler {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* force trigger full block report multi times, the next block report
|
|
||||||
* must be scheduled in the range (now + BLOCK_REPORT_INTERVAL_SEC).
|
|
||||||
*/
|
|
||||||
@Test
|
|
||||||
public void testScheduleNextBlockReport4() {
|
|
||||||
for (final long now : getTimestamps()) {
|
|
||||||
Scheduler scheduler = makeMockScheduler(now);
|
|
||||||
for (int i = 0; i < getTimestamps().size(); ++i) {
|
|
||||||
scheduler.forceFullBlockReportNow();
|
|
||||||
scheduler.scheduleNextBlockReport();
|
|
||||||
}
|
|
||||||
assertTrue(scheduler.getNextBlockReportTime() - now >= 0);
|
|
||||||
assertTrue(scheduler.getNextBlockReportTime() - now <= BLOCK_REPORT_INTERVAL_MS);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testScheduleHeartbeat() {
|
public void testScheduleHeartbeat() {
|
||||||
for (final long now : getTimestamps()) {
|
for (final long now : getTimestamps()) {
|
||||||
|
|
Loading…
Reference in New Issue