This is an automated email from the ASF dual-hosted git repository.
sumitagrawal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 2ff58b3195d HDDS-13709. Fix freon streaming command with duration.
(#9065)
2ff58b3195d is described below
commit 2ff58b3195da860c4cca7a3a946d78a80e2f34fe
Author: Ashish Kumar <[email protected]>
AuthorDate: Fri Sep 26 09:28:36 2025 +0530
HDDS-13709. Fix freon streaming command with duration. (#9065)
---
.../main/java/org/apache/hadoop/ozone/freon/BaseFreonGenerator.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git
a/hadoop-ozone/freon/src/main/java/org/apache/hadoop/ozone/freon/BaseFreonGenerator.java
b/hadoop-ozone/freon/src/main/java/org/apache/hadoop/ozone/freon/BaseFreonGenerator.java
index ac58f718554..8466f3e6aa1 100644
---
a/hadoop-ozone/freon/src/main/java/org/apache/hadoop/ozone/freon/BaseFreonGenerator.java
+++
b/hadoop-ozone/freon/src/main/java/org/apache/hadoop/ozone/freon/BaseFreonGenerator.java
@@ -26,8 +26,6 @@
import io.opentelemetry.api.trace.StatusCode;
import java.io.IOException;
import java.io.InputStream;
-import java.time.Duration;
-import java.time.Instant;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.ExecutorService;
@@ -327,8 +325,7 @@ public void init() {
LongSupplier supplier;
if (duration != null) {
maxValue = durationInSecond;
- supplier = () -> Duration.between(
- Instant.ofEpochMilli(startTime), Instant.now()).getSeconds();
+ supplier = () -> (Time.monotonicNow() - startTime) / 1000;
} else {
maxValue = testNo;
supplier = () -> successCounter.get() + failureCounter.get();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
