diff --git a/tests/system-test/2-query/distribute_agg_max.py b/tests/system-test/2-query/distribute_agg_max.py
index 6897d7dc4f3003032305368fa6cbbce871e958a0..ae0ab5aafab4b64ac9072b4de392d4359a4129de 100644
--- a/tests/system-test/2-query/distribute_agg_max.py
+++ b/tests/system-test/2-query/distribute_agg_max.py
@@ -39,7 +39,7 @@ class TDTestCase:
     def prepare_datas_of_distribute(self):
         
         # prepate datas for  20 tables distributed at different vgroups
-        tdSql.execute("create database if not exists testdb keep 3650 days 1000 vgroups 5")
+        tdSql.execute("create database if not exists testdb keep 3650 duration 1000 vgroups 5")
         tdSql.execute(" use testdb ")
         tdSql.execute(
             '''create table stb1
diff --git a/tests/system-test/2-query/max.py b/tests/system-test/2-query/max.py
index 19dd55a0e6c7017185cbb2d382b50069bcc13c6e..0cb470088b09d6588974251ae6e7f0e1098e291f 100644
--- a/tests/system-test/2-query/max.py
+++ b/tests/system-test/2-query/max.py
@@ -93,7 +93,7 @@ class TDTestCase:
     def support_distributed_aggregate(self):
         
         # prepate datas for  20 tables distributed at different vgroups
-        tdSql.execute("create database if not exists testdb keep 3650 days 1000 vgroups 5")
+        tdSql.execute("create database if not exists testdb keep 3650 duration 1000 vgroups 5")
         tdSql.execute(" use testdb ")
         tdSql.execute(
             '''create table stb1