fix: fixing bugs that arise from different compute monitors

1 files changed, 8 insertions, 14 deletions

diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt
index b07a50ae..846bde5a 100644
--- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt
+++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt
@@ -30,6 +30,7 @@ import org.opendc.compute.simulator.provisioner.setupComputeService
 import org.opendc.compute.simulator.provisioner.setupHosts
 import org.opendc.compute.simulator.scheduler.ComputeScheduler
 import org.opendc.compute.simulator.service.ComputeService
+import org.opendc.compute.simulator.telemetry.KafkaComputeMonitor
 import org.opendc.compute.simulator.telemetry.parquet.ComputeExportConfig
 import org.opendc.compute.simulator.telemetry.parquet.ParquetComputeMonitor
 import org.opendc.compute.simulator.telemetry.parquet.withGpuColumns
@@ -135,11 +136,7 @@ public fun runScenario(
                 provisioner,
                 serviceDomain,
                 scenario,
-                seed,
                 startTime,
-                scenario.id,
-                computeExportConfig =
-                    scenario.exportModelSpec.computeExportConfig.withGpuColumns(gpuCount),
             )
 
             val service = provisioner.registry.resolve(serviceDomain, ComputeService::class.java)!!
@@ -192,21 +189,18 @@ public fun addExportModel(
     provisioner: Provisioner,
     serviceDomain: String,
     scenario: Scenario,
-    seed: Long,
     startTime: Duration,
-    index: Int,
-    computeExportConfig: ComputeExportConfig = scenario.exportModelSpec.computeExportConfig,
 ) {
+
+    /*
+    * Here is the entry point to KafkaComputeMonitor().
+    * With this setting, the simulator no longer writes to parquet files.
+    * To get back the original code, refer to https://github.com/atlarge-research/opendc
+    * */
     provisioner.runStep(
         registerComputeMonitor(
             serviceDomain,
-            ParquetComputeMonitor(
-                File("${scenario.outputFolder}/raw-output/$index"),
-                "seed=$seed",
-                bufferSize = 4096,
-                scenario.exportModelSpec.filesToExportDict,
-                computeExportConfig = computeExportConfig,
-            ),
+            KafkaComputeMonitor(),
             Duration.ofSeconds(scenario.exportModelSpec.exportInterval),
             startTime,
             scenario.exportModelSpec.filesToExportDict,