Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Check for interrupts in gapfill main loop #4968

Merged
merged 1 commit into from Nov 15, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
3 changes: 3 additions & 0 deletions CHANGELOG.md
Expand Up @@ -29,11 +29,14 @@ argument or resolve the type ambiguity by casting to the intended type.
* #4840 Fix performance regressions in the copy code
* #4823 Fix a crash that could occur when using nested user-defined functions with hypertables
* #4898 Fix cagg migration failure when trying to resume
* #4910 Fix a typo in process_compressed_data_out
* #4955 Fix cagg migration for hypertables using timestamp without timezone
* #4968 Check for interrupts in gapfill main loop

**Thanks**
* @jflambert for reporting a crash with nested user-defined functions.
* @jvanns for reporting hypertable FK reference to vanilla PostgreSQL partitioned table doesn't seem to work
* @kou for fixing a typo in process_compressed_data_out
* @xvaara for helping reproduce a bug with bitmap scans in transparent decompression

## 2.8.1 (2022-10-06)
Expand Down
3 changes: 3 additions & 0 deletions tsl/src/nodes/gapfill/gapfill_exec.c
Expand Up @@ -11,6 +11,7 @@
#include <catalog/pg_cast.h>
#include <catalog/pg_collation.h>
#include <catalog/pg_type.h>
#include <miscadmin.h>
#include <nodes/extensible.h>
#include <nodes/makefuncs.h>
#include <nodes/nodeFuncs.h>
Expand Down Expand Up @@ -810,6 +811,8 @@ gapfill_exec(CustomScanState *node)

while (true)
{
CHECK_FOR_INTERRUPTS();

/* fetch next tuple from subplan */
if (FETCHED_NONE == state->state)
{
Expand Down