diff options
Diffstat (limited to 'src/backend/executor/nodeHashjoin.c')
| -rw-r--r-- | src/backend/executor/nodeHashjoin.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/backend/executor/nodeHashjoin.c b/src/backend/executor/nodeHashjoin.c index 26da3b2fdf5..0e7ca625cee 100644 --- a/src/backend/executor/nodeHashjoin.c +++ b/src/backend/executor/nodeHashjoin.c @@ -19,6 +19,7 @@ #include "executor/hashjoin.h" #include "executor/nodeHash.h" #include "executor/nodeHashjoin.h" +#include "miscadmin.h" #include "utils/memutils.h" @@ -263,6 +264,13 @@ ExecHashJoin(HashJoinState *node) case HJ_SCAN_BUCKET: /* + * We check for interrupts here because this corresponds to + * where we'd fetch a row from a child plan node in other + * join types. + */ + CHECK_FOR_INTERRUPTS(); + + /* * Scan the selected hash bucket for matches to current outer */ if (!ExecScanHashBucket(node, econtext)) |