Fix review comments

src/backend/distributed/connection/connection_management.c

@@ -1475,6 +1475,7 @@ ShouldShutdownConnection(MultiConnection *connection, const int cachedConnection
 		   connection->forceCloseAtTransactionEnd ||
 		   PQstatus(connection->pgConn) != CONNECTION_OK ||
 		   !RemoteTransactionIdle(connection) ||
+		   connection->requiresReplication ||
 		   (MaxCachedConnectionLifetime >= 0 &&
 			MillisecondsToTimeout(connection->connectionEstablishmentStart,
 								  MaxCachedConnectionLifetime) <= 0);

src/backend/distributed/operations/shard_split.c

@@ -234,15 +234,6 @@ ErrorIfCannotSplitShardExtended(SplitOperation splitOperation,
 							   SplitTargetName[splitOperation])));
 	}
 
-	if (extern_IsColumnarTableAmTable(shardIntervalToSplit->relationId))
-	{
-		ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
-						errmsg("Cannot %s %s as operation "
-							   "is not supported for Columnar tables.",
-							   SplitOperationName[splitOperation],
-							   SplitTargetName[splitOperation])));
-	}
-
 	uint32 relationReplicationFactor = TableShardReplicationFactor(
 		shardIntervalToSplit->relationId);
 	if (relationReplicationFactor > 1)

src/backend/distributed/replication/multi_logical_replication.c

@@ -2109,7 +2109,7 @@ CreateShardSplitSubscription(MultiConnection *connection, char *sourceNodeName,
 															SHARD_SPLIT_SUBSCRIPTION_PREFIX)),
 					 quote_literal_cstr(conninfo->data),
 					 quote_identifier(publicationName),
-					 slotName);
+					 escape_param_str(slotName));
 
 	ExecuteCriticalRemoteCommand(connection, createSubscriptionCommand->data);
 	pfree(createSubscriptionCommand->data);