diff --git a/utils/kvrocks2redis/tests/check_consistency.py b/utils/kvrocks2redis/tests/check_consistency.py
index 3a176cc87ec..72477978120 100644
--- a/utils/kvrocks2redis/tests/check_consistency.py
+++ b/utils/kvrocks2redis/tests/check_consistency.py
@@ -100,7 +100,7 @@ def _import_and_compare(self, num):
             self.src_cli.incr(incr_key)
             hash_key = f'hash_key_{i}'
             hash_value = {'field1': f'field1_value_{i}', 'field2': f'field2_value_{i}'}
-            self.src_cli.hmset(hash_key, hash_value)
+            self.src_cli.hset(hash_key, mapping=hash_value)
             set_key = f'set_key_{i}'
             set_value = [f'set_value_{i}_1', f'set_value_{i}_2', f'set_value_{i}_3']
             self.src_cli.sadd(set_key, *set_value)
@@ -129,4 +129,4 @@ def _import_and_compare(self, num):
     args = parser.parse_args()
 
     redis_comparator = RedisComparator(args.src_host, args.src_port, args.src_password, args.dst_host, args.dst_port, args.dst_password)
-    redis_comparator.compare_redis_data(args.key_file)
\ No newline at end of file
+    redis_comparator.compare_redis_data(args.key_file)