Fixed cleanUp path

blootsvoets · blootsvoets · commit ee07e006149a · 2017-08-31T14:23:16.000+02:00
diff --git a/src/main/java/org/radarcns/RestructureAvroRecords.java b/src/main/java/org/radarcns/RestructureAvroRecords.java
@@ -184,7 +184,7 @@ public void start(String directoryName) throws IOException {
         }
 
         logger.info("Cleaning offset file");
-        OffsetRangeFile.cleanUp(outputPath);
+        OffsetRangeFile.cleanUp(offsetsPath);
     }
 
     private static String getTopic(Path filePath, OffsetRangeSet seenFiles) {

Original file line number	Diff line number	Diff line change
`@@ -184,7 +184,7 @@ public void start(String directoryName) throws IOException {`
`184`	`184`	`}`
`185`	`185`
`186`	`186`	`logger.info("Cleaning offset file");`
`187`		`- OffsetRangeFile.cleanUp(outputPath);`
	`187`	`+ OffsetRangeFile.cleanUp(offsetsPath);`
`188`	`188`	`}`
`189`	`189`
`190`	`190`	`private static String getTopic(Path filePath, OffsetRangeSet seenFiles) {`