From ebd375d524714708d7b38c0117a77d50d23043a3 Mon Sep 17 00:00:00 2001
From: Fabian Mastenbroek <mail.fabianm@gmail.com>
Date: Thu, 1 Oct 2020 10:42:36 +0200
Subject: Add test case for WTA trace parser

---
 .../src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'simulator/opendc-format/src/main')

diff --git a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt
index b8f3e771..12a60aec 100644
--- a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt
+++ b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt
@@ -55,7 +55,7 @@ class WtfTraceReader(path: String) : TraceReader<Job> {
         val tasks = mutableMapOf<Long, Task>()
         val taskDependencies = mutableMapOf<Task, List<Long>>()
 
-        val reader = AvroParquetReader.builder<GenericRecord>(Path(path)).build()
+        val reader = AvroParquetReader.builder<GenericRecord>(Path(path, "tasks/schema-1.0")).build()
 
         while (true) {
             val nextRecord = reader.read() ?: break
-- 
cgit v1.2.3