diff --git a/src/pipelines/dbf_to_postgres_ctllog.py b/src/pipelines/dbf_to_postgres_ctllog.py
index 9b209f1..547e66e 100644
--- a/src/pipelines/dbf_to_postgres_ctllog.py
+++ b/src/pipelines/dbf_to_postgres_ctllog.py
@@ -32,7 +32,7 @@ class DbfToPostgresCtllogPipeline(BasePipeline):
 
         self.db = None
         self.group_cache = {}
-        self.batch_size = os.getenv('BATCH_SIZE', 1000)
+        self.batch_size = int(os.getenv('BATCH_SIZE', 1000))
         self.batch_data = []
         self.processed_records = 0
         self.current_date = None  # 当前处理的日期