diff --git a/src/gausskernel/ddes/adapter/ss_init.cpp b/src/gausskernel/ddes/adapter/ss_init.cpp
index 54b437919..a4f862cbc 100644
--- a/src/gausskernel/ddes/adapter/ss_init.cpp
+++ b/src/gausskernel/ddes/adapter/ss_init.cpp
@@ -377,6 +377,7 @@ static void setDMSProfile(dms_profile_t* profile)
     profile->enable_reform = (unsigned char)dms_attr->enable_reform;
     profile->load_balance_mode = 1; /* primary-standby */
     profile->parallel_thread_num = dms_attr->parallel_thread_num;
+    profile->max_wait_time = DMS_MSG_MAX_WAIT_TIME;
 
     if (dms_attr->enable_ssl && g_instance.attr.attr_security.EnableSSL) {
         InitDmsSSL();
diff --git a/src/include/ddes/dms/ss_common_attr.h b/src/include/ddes/dms/ss_common_attr.h
index c04d0a63a..fca52f775 100644
--- a/src/include/ddes/dms/ss_common_attr.h
+++ b/src/include/ddes/dms/ss_common_attr.h
@@ -186,6 +186,8 @@
 #define SS_ACQUIRE_LOCK_DO_NOT_WAIT 0
 #define SS_ACQUIRE_LOCK_RETRY_INTERVAL (50)   // 50ms
 
+#define DMS_MSG_MAX_WAIT_TIME (10 * 1000) // 10s
+
 typedef enum SSBroadcastOp {
     BCAST_GET_XMIN = 0,
     BCAST_CANCEL_TRX_FOR_SWITCHOVER,