diff --git a/model/graph_entity/file_utils.py b/model/graph_entity/file_utils.py
index 2795ed2..630e8f1 100644
--- a/model/graph_entity/file_utils.py
+++ b/model/graph_entity/file_utils.py
@@ -94,6 +94,7 @@ def write(meta_node: Node):
                 if meta_node['timestamp']:
                     meta_node['timestamp'] = str(meta_node['timestamp'])
                 json.dump(meta_node, f, ensure_ascii=False, indent=4)
+                f.flush()
 
     return Writer()
 
@@ -119,6 +120,7 @@ def write(self, data_node: Node):
             row = [str(data_node[field]).replace("\n", " ").strip() for field in FIELD_NAMES]
             line = ",".join(row)
             self.file_handle.write(line + "\n")
+            self.file_handle.flush()
 
         def __del__(self):
             self.file_handle.flush()