|
@@ -2569,7 +2569,7 @@ public class DataNode extends ReconfigurableBase
|
|
if (this.threadGroup != null) {
|
|
if (this.threadGroup != null) {
|
|
int sleepMs = 2;
|
|
int sleepMs = 2;
|
|
while (true) {
|
|
while (true) {
|
|
- // When shutting down for restart, wait 2.5 seconds before forcing
|
|
|
|
|
|
+ // When shutting down for restart, wait 1 second before forcing
|
|
// termination of receiver threads.
|
|
// termination of receiver threads.
|
|
if (!this.shutdownForUpgrade ||
|
|
if (!this.shutdownForUpgrade ||
|
|
(this.shutdownForUpgrade && (Time.monotonicNow() - timeNotified
|
|
(this.shutdownForUpgrade && (Time.monotonicNow() - timeNotified
|