Fix cancellation of real time queries

src/backend/distributed/executor/multi_real_time_executor.c

@@ -199,6 +199,15 @@ MultiRealTimeExecute(Job *job)
 		{
 			MultiClientWait(waitInfo);
 		}
+
+#ifdef WIN32
+		/*
+		 * Don't call CHECK_FOR_INTERRUPTS because we want to clean up after ourselves,
+		 * calling pgwin32_dispatch_queued_signals sets QueryCancelPending so we leave
+		 * the loop.
+		 */
+		pgwin32_dispatch_queued_signals();
+#endif
 	}
 
 	MultiClientFreeWaitInfo(waitInfo);