You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cn...@apache.org on 2022/06/10 19:58:03 UTC
[hadoop] branch branch-3.2 updated: HDFS-16623. Avoid IllegalArgumentException in LifelineSender (#4409)
This is an automated email from the ASF dual-hosted git repository.
cnauroth pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.2 by this push:
new aba44189816 HDFS-16623. Avoid IllegalArgumentException in LifelineSender (#4409)
aba44189816 is described below
commit aba44189816fea529f56da2e214a3d35a7aaf5e2
Author: xuzq <15...@163.com>
AuthorDate: Sat Jun 11 03:00:56 2022 +0800
HDFS-16623. Avoid IllegalArgumentException in LifelineSender (#4409)
* HDFS-16623. Avoid IllegalArgumentException in LifelineSender
Co-authored-by: zengqiang.xu <ze...@shopee.com>
(cherry picked from commit af5003a47311bad542964c42c1f776e4350446b9)
(cherry picked from commit ee3ee98ee5a4c34da7a4960b099686bdc1186a71)
---
.../apache/hadoop/hdfs/server/datanode/BPServiceActor.java | 3 ++-
.../hdfs/server/datanode/TestBpServiceActorScheduler.java | 13 +++++++++++++
2 files changed, 15 insertions(+), 1 deletion(-)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
index ea914024699..0b3eb14dff8 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
@@ -1241,7 +1241,8 @@ class BPServiceActor implements Runnable {
}
long getLifelineWaitTime() {
- return nextLifelineTime - monotonicNow();
+ long waitTime = nextLifelineTime - monotonicNow();
+ return waitTime > 0 ? waitTime : 0;
}
/**
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBpServiceActorScheduler.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBpServiceActorScheduler.java
index 438be89be92..0bd450bed7e 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBpServiceActorScheduler.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBpServiceActorScheduler.java
@@ -18,6 +18,7 @@
package org.apache.hadoop.hdfs.server.datanode;
+import org.apache.hadoop.util.Time;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.hadoop.hdfs.server.datanode.BPServiceActor.Scheduler;
@@ -182,6 +183,18 @@ public class TestBpServiceActorScheduler {
}
}
+ @Test
+ public void testScheduleLifelineScheduleTime() {
+ Scheduler mockScheduler = spy(new Scheduler(
+ HEARTBEAT_INTERVAL_MS, LIFELINE_INTERVAL_MS,
+ BLOCK_REPORT_INTERVAL_MS, OUTLIER_REPORT_INTERVAL_MS));
+ long now = Time.monotonicNow();
+ mockScheduler.scheduleNextLifeline(now);
+ long mockMonotonicNow = now + LIFELINE_INTERVAL_MS * 2;
+ doReturn(mockMonotonicNow).when(mockScheduler).monotonicNow();
+ assertTrue(mockScheduler.getLifelineWaitTime() >= 0);
+ }
+
@Test
public void testOutlierReportScheduling() {
for (final long now : getTimestamps()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org