diff --git a/src/backend/distributed/connection/remote_commands.c b/src/backend/distributed/connection/remote_commands.c index da484a13b..6e3fa3081 100644 --- a/src/backend/distributed/connection/remote_commands.c +++ b/src/backend/distributed/connection/remote_commands.c @@ -1042,6 +1042,12 @@ SendCancelationRequest(MultiConnection *connection) { char errorBuffer[ERROR_BUFFER_SIZE] = { 0 }; + if (!PQisBusy(connection->pgConn)) + { + /* no statement in progress, nothing to cancel */ + return false; + } + PGcancel *cancelObject = PQgetCancel(connection->pgConn); if (cancelObject == NULL) {