diff --git a/vnpy/app/csv_loader/engine.py b/vnpy/app/csv_loader/engine.py
index 2c384d02..c0547036 100644
--- a/vnpy/app/csv_loader/engine.py
+++ b/vnpy/app/csv_loader/engine.py
@@ -107,7 +107,7 @@ class CsvLoaderEngine(BaseEngine):
 
         # Insert into DB
         with DB.atomic():
-            for batch in chunked(db_bars, 500):
+            for batch in chunked(db_bars, 50):
                 DbBarData.insert_many(batch).on_conflict_replace().execute()
 
         return start, end, count