diff --git a/src/pipelines/dbf_to_postgres_ctllog.py b/src/pipelines/dbf_to_postgres_ctllog.py
index e55a2f8..9c6e326 100644
--- a/src/pipelines/dbf_to_postgres_ctllog.py
+++ b/src/pipelines/dbf_to_postgres_ctllog.py
@@ -153,7 +153,7 @@ class DbfToPostgresCtllogPipeline(BasePipeline):
                     if len(batch_data) >= batch_size:
                         # todo：本地调试先注释掉
                         self.db.execute_batch(
-                            "INSERT INTO current_states (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)",
+                            "INSERT INTO controller_log (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)",
                             batch_data
                         )
                         # todo：本地调试先注释掉
@@ -169,7 +169,7 @@ class DbfToPostgresCtllogPipeline(BasePipeline):
             if batch_data:
                 # todo：本地调试先注释掉
                 self.db.execute_batch(
-                    "INSERT INTO current_states (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)",
+                    "INSERT INTO controller_log (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)",
                     batch_data
                 )
                 # todo：本地调试先注释掉