Revert "skip to get worker stats for kop test"

This reverts commit 7446630.
streamnative · Jul 31, 2023 · 94354a6 · 94354a6
1 parent 4ef3abd
commit 94354a6
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java b/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java
@@ -126,7 +126,7 @@ public TestResult run() throws Exception {
 
         if (workload.warmupDurationMinutes > 0) {
             log.info("----- Starting warm-up traffic ({}m) ------", workload.warmupDurationMinutes);
-//            printAndCollectStats(workload.warmupDurationMinutes, TimeUnit.MINUTES);
+            printAndCollectStats(workload.warmupDurationMinutes, TimeUnit.MINUTES);
         }
 
         if (workload.consumerBacklogSizeGB > 0) {
@@ -143,11 +143,11 @@ public TestResult run() throws Exception {
         worker.resetStats();
         log.info("----- Starting benchmark traffic ({}m)------", workload.testDurationMinutes);
 
-//        TestResult result = printAndCollectStats(workload.testDurationMinutes, TimeUnit.MINUTES);
+        TestResult result = printAndCollectStats(workload.testDurationMinutes, TimeUnit.MINUTES);
         runCompleted = true;
 
         worker.stopAll();
-        return new TestResult();
+        return result;
     }
 
     private void ensureTopicsAreReady() throws IOException {