From 035c91ae7f5e8cd1eca32acdf8dc417fa1fa8713 Mon Sep 17 00:00:00 2001
From: Onder Kalaci <onderkalaci@gmail.com>
Date: Tue, 29 Nov 2022 16:33:34 +0100
Subject: [PATCH] WIP

---
 src/backend/distributed/utils/listutils.c | 7 +++++++
 1 file changed, 7 insertions(+)

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)