diff --git a/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java b/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java
index 45b3c488..be5ea075 100644
--- 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,8 +143,7 @@ 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();