diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/backend/optimizer/path/allpaths.c | 15 | ||||
| -rw-r--r-- | src/backend/utils/misc/guc.c | 11 | ||||
| -rw-r--r-- | src/backend/utils/misc/postgresql.conf.sample | 1 | ||||
| -rw-r--r-- | src/include/optimizer/paths.h | 1 |
4 files changed, 23 insertions, 5 deletions
diff --git a/src/backend/optimizer/path/allpaths.c b/src/backend/optimizer/path/allpaths.c index cc8ba61bb0c..2e4b670e069 100644 --- a/src/backend/optimizer/path/allpaths.c +++ b/src/backend/optimizer/path/allpaths.c @@ -15,6 +15,7 @@ #include "postgres.h" +#include <limits.h> #include <math.h> #include "access/sysattr.h" @@ -56,6 +57,7 @@ typedef struct pushdown_safety_info /* These parameters are set by GUC */ bool enable_geqo = false; /* just in case GUC doesn't set it */ int geqo_threshold; +int min_parallel_relation_size; /* Hook for plugins to get control in set_rel_pathlist() */ set_rel_pathlist_hook_type set_rel_pathlist_hook = NULL; @@ -690,7 +692,7 @@ create_plain_partial_paths(PlannerInfo *root, RelOptInfo *rel) parallel_workers = rel->rel_parallel_workers; else { - int parallel_threshold = 1000; + int parallel_threshold; /* * If this relation is too small to be worth a parallel scan, just @@ -699,21 +701,24 @@ create_plain_partial_paths(PlannerInfo *root, RelOptInfo *rel) * might not be worthwhile just for this relation, but when combined * with all of its inheritance siblings it may well pay off. */ - if (rel->pages < parallel_threshold && + if (rel->pages < (BlockNumber) min_parallel_relation_size && rel->reloptkind == RELOPT_BASEREL) return; /* * Select the number of workers based on the log of the size of the * relation. This probably needs to be a good deal more - * sophisticated, but we need something here for now. + * sophisticated, but we need something here for now. Note that the + * upper limit of the min_parallel_relation_size GUC is chosen to + * prevent overflow here. */ parallel_workers = 1; - while (rel->pages > parallel_threshold * 3) + parallel_threshold = Max(min_parallel_relation_size, 1); + while (rel->pages >= (BlockNumber) (parallel_threshold * 3)) { parallel_workers++; parallel_threshold *= 3; - if (parallel_threshold >= PG_INT32_MAX / 3) + if (parallel_threshold > INT_MAX / 3) break; /* avoid overflow */ } } diff --git a/src/backend/utils/misc/guc.c b/src/backend/utils/misc/guc.c index 9b02111a834..60148b871b3 100644 --- a/src/backend/utils/misc/guc.c +++ b/src/backend/utils/misc/guc.c @@ -2748,6 +2748,17 @@ static struct config_int ConfigureNamesInt[] = }, { + {"min_parallel_relation_size", PGC_USERSET, QUERY_TUNING_COST, + gettext_noop("Sets the minimum size of relations to be considered for parallel scan."), + NULL, + GUC_UNIT_BLOCKS, + }, + &min_parallel_relation_size, + 1024, 0, INT_MAX / 3, + NULL, NULL, NULL + }, + + { /* Can't be set in postgresql.conf */ {"server_version_num", PGC_INTERNAL, PRESET_OPTIONS, gettext_noop("Shows the server version as an integer."), diff --git a/src/backend/utils/misc/postgresql.conf.sample b/src/backend/utils/misc/postgresql.conf.sample index 8260e371bc9..3fa05403bbc 100644 --- a/src/backend/utils/misc/postgresql.conf.sample +++ b/src/backend/utils/misc/postgresql.conf.sample @@ -304,6 +304,7 @@ #cpu_operator_cost = 0.0025 # same scale as above #parallel_tuple_cost = 0.1 # same scale as above #parallel_setup_cost = 1000.0 # same scale as above +#min_parallel_relation_size = 8MB #effective_cache_size = 4GB # - Genetic Query Optimizer - diff --git a/src/include/optimizer/paths.h b/src/include/optimizer/paths.h index f3b25e2419c..cc6f85d6dbf 100644 --- a/src/include/optimizer/paths.h +++ b/src/include/optimizer/paths.h @@ -22,6 +22,7 @@ */ extern bool enable_geqo; extern int geqo_threshold; +extern int min_parallel_relation_size; /* Hook for plugins to get control in set_rel_pathlist() */ typedef void (*set_rel_pathlist_hook_type) (PlannerInfo *root, |