diff --git a/mediator/mediator.go b/mediator/mediator.go
index a5d21a621..9dc669b2a 100644
--- a/mediator/mediator.go
+++ b/mediator/mediator.go
@@ -168,7 +168,9 @@ func (m *Mediator) parseCSV(cdrfn string) (err error) {
 		}
 		record = append(record, cost)
 		w.WriteString(strings.Join(record, ",") + "\n")
+
 	}
+	w.Flush()
 	return
 }