diff --git a/src/backend/distributed/utils/listutils.c b/src/backend/distributed/utils/listutils.c
index 3279193ef..b94b880a7 100644
--- a/src/backend/distributed/utils/listutils.c
+++ b/src/backend/distributed/utils/listutils.c
@@ -196,6 +196,13 @@ StringJoinParams(List *stringList, char delimiter, char *prefix, char *postfix)
 		}
 		appendStringInfoString(joinedString, command);
 		curIndex++;
+
+		if (curIndex % 50 == 0)
+		{
+			appendStringInfoChar(joinedString, delimiter);
+			appendStringInfo(joinedString, "SAVEPOINT citus_int_%d;", curIndex);
+
+		}
 	}
 
 	if (postfix != NULL)