diff --git a/src/DDBBase.py b/src/DDBBase.py
index 368fb31..6252454 100644
--- a/src/DDBBase.py
+++ b/src/DDBBase.py
@@ -5,7 +5,7 @@ import dolphindb as ddb
 class DDBBase(object):
 
     ddb_config = {
-        'host' : '192.168.1.167',
+        'host' : '192.168.1.7',
         'username' : 'admin',
         'password' : '123456',
     }
diff --git a/src/loader/DDBHFTLoader.py b/src/loader/DDBHFTLoader.py
index 69b7087..5bcb6d4 100644
--- a/src/loader/DDBHFTLoader.py
+++ b/src/loader/DDBHFTLoader.py
@@ -365,8 +365,9 @@ class DDBHFTLoader(DDBLoader):
         elif (type_name, stock_id, 'START') in self.dump_journal_df.index:
             # 任务已经开始，但是没有完全结束，就需要逐个检查日期，跳过已经录入输入的交易日数据
             # 同时，也不会再往日志文件中写入START记录
+            partitioned_table_name = type_name + self.ddb_partition_table_suffix 
             _journal_dt = self.ddb_sess.run(f"""
-                    select m_nDate from tbl where code='{stock_id}' group by m_nDate map;
+                    select m_nDate from loadTable("{self.ddb_path}", "{partitioned_table_name}") where code='{stock_id}' group by m_nDate map;
                 """).set_index('m_nDate')
         else:
             _journal_dt = None