Fix

Signed-off-by: Tyler Gu <[email protected]>

performance_measurement/measure_performance.py

@@ -5,15 +5,15 @@
 import logging
 import os
 import sys
-from datetime import datetime
 import threading
+from datetime import datetime
 from typing import Callable
 
 import yaml
-from measure_runner import ConditionFuncType, MeasurementRunner
 from fluent_inputs import FluentInputGenerator
-from stats_watch import WatchStats
+from measure_runner import MeasurementRunner
 from rabbitmq_inputs import RabbitMQInputGenerator
+from stats_watch import WatchStats
 from zk_inputs import ZooKeeperInputGenerator
 
 sys.path.insert(0, os.path.abspath(
@@ -98,7 +98,7 @@ def test_normal(
 
         single_operation_trial_dir = f"{workdir}/trial-single-operation"
         os.makedirs(single_operation_trial_dir, exist_ok=True)
-        control_plane_stats_dir = os.path.join(trial_dir, "control_plane_stats")
+        control_plane_stats_dir = os.path.join(single_operation_trial_dir, "control_plane_stats")
         os.makedirs(control_plane_stats_dir, exist_ok=True)
         gen = 0
         for workload in workloads: