Revert "Fix accumulation of parallel worker instrumentation."

This reverts commit 778e78ae9fa51e58f41cbdc72b293291d02d8984.  Per
further discussion, that doesn't seem to be the best possible fix.

Discussion: http://postgr.es/m/CAA4eK1LW2aFKzY3=vwvc=t-juzPPVWP2uT1bpx_MeyEqnM+p8g@mail.gmail.com

diff --git a/src/backend/executor/execParallel.c b/src/backend/executor/execParallel.c
index 42c3e473a9a0d156f79de1fbe05e02cb64d5adba..7dda399daf351fc7e5297b985ec2cc42f11c244d 100644 (file)
--- a/src/backend/executor/execParallel.c
+++ b/src/backend/executor/execParallel.c
@@ -612,19 +612,6 @@ ExecParallelReinitialize(PlanState *planstate,
        /* Old workers must already be shut down */
        Assert(pei->finished);
 
-       /* Clear the instrumentation space from the last round. */
-       if (pei->instrumentation)
-       {
-               Instrumentation *instrument;
-               SharedExecutorInstrumentation *sh_instr;
-               int                     i;
-
-               sh_instr = pei->instrumentation;
-               instrument = GetInstrumentationArray(sh_instr);
-               for (i = 0; i < sh_instr->num_workers * sh_instr->num_plan_nodes; ++i)
-                       InstrInit(&instrument[i], pei->planstate->state->es_instrument);
-       }
-
        ReinitializeParallelDSM(pei->pcxt);
        pei->tqueue = ExecParallelSetupTupleQueues(pei->pcxt, true);
        pei->reader = NULL;
@@ -712,33 +699,21 @@ ExecParallelRetrieveInstrumentation(PlanState *planstate,
        for (n = 0; n < instrumentation->num_workers; ++n)
                InstrAggNode(planstate->instrument, &instrument[n]);
 
-       if (!planstate->worker_instrument)
-       {
-               /*
-                * Allocate space for the per-worker detail.
-                *
-                * Worker instrumentation should be allocated in the same context as
-                * the regular instrumentation information, which is the per-query
-                * context. Switch into per-query memory context.
-                */
-               oldcontext = MemoryContextSwitchTo(planstate->state->es_query_cxt);
-               ibytes =
-                       mul_size(instrumentation->num_workers, sizeof(Instrumentation));
-               planstate->worker_instrument =
-                       palloc(ibytes + offsetof(WorkerInstrumentation, instrument));
-               MemoryContextSwitchTo(oldcontext);
-
-               for (n = 0; n < instrumentation->num_workers; ++n)
-                       InstrInit(&planstate->worker_instrument->instrument[n],
-                                         planstate->state->es_instrument);
-       }
+       /*
+        * Also store the per-worker detail.
+        *
+        * Worker instrumentation should be allocated in the same context as the
+        * regular instrumentation information, which is the per-query context.
+        * Switch into per-query memory context.
+        */
+       oldcontext = MemoryContextSwitchTo(planstate->state->es_query_cxt);
+       ibytes = mul_size(instrumentation->num_workers, sizeof(Instrumentation));
+       planstate->worker_instrument =
+               palloc(ibytes + offsetof(WorkerInstrumentation, instrument));
+       MemoryContextSwitchTo(oldcontext);
 
        planstate->worker_instrument->num_workers = instrumentation->num_workers;
-
-       /* Accumulate the per-worker detail. */
-       for (n = 0; n < instrumentation->num_workers; ++n)
-               InstrAggNode(&planstate->worker_instrument->instrument[n],
-                                        &instrument[n]);
+       memcpy(&planstate->worker_instrument->instrument, instrument, ibytes);
 
        return planstate_tree_walker(planstate, ExecParallelRetrieveInstrumentation,
                                                                 instrumentation);

diff --git a/src/test/regress/expected/select_parallel.out b/src/test/regress/expected/select_parallel.out
index 1fc29c1bbbb991eab0ec51d6c9de75bca9b1c2ef..ecabd35cca6573cecc08192f350c65b5296ce0f5 100644 (file)
--- a/src/test/regress/expected/select_parallel.out
+++ b/src/test/regress/expected/select_parallel.out
@@ -300,28 +300,7 @@ select count(*) from bmscantest where a>1;
  99999
 (1 row)
 
--- test accumulation of stats for parallel node
 reset enable_seqscan;
-alter table tenk2 set (parallel_workers = 0);
-explain (analyze, timing off, summary off, costs off)
-       select count(*) from tenk1, tenk2 where tenk1.hundred > 1
-        and tenk2.thousand=0;
-                                QUERY PLAN                                
---------------------------------------------------------------------------
- Aggregate (actual rows=1 loops=1)
-   ->  Nested Loop (actual rows=98000 loops=1)
-         ->  Seq Scan on tenk2 (actual rows=10 loops=1)
-               Filter: (thousand = 0)
-               Rows Removed by Filter: 9990
-         ->  Gather (actual rows=9800 loops=10)
-               Workers Planned: 4
-               Workers Launched: 4
-               ->  Parallel Seq Scan on tenk1 (actual rows=1960 loops=50)
-                     Filter: (hundred > 1)
-                     Rows Removed by Filter: 40
-(11 rows)
-
-alter table tenk2 reset (parallel_workers);
 reset enable_indexscan;
 reset enable_hashjoin;
 reset enable_mergejoin;

diff --git a/src/test/regress/sql/select_parallel.sql b/src/test/regress/sql/select_parallel.sql
index 599a14f44fe0a8459c04a34cedaaf3b5a8265942..280c78765362bd44cdba3daf33ca47823a1764ea 100644 (file)
--- a/src/test/regress/sql/select_parallel.sql
+++ b/src/test/regress/sql/select_parallel.sql
@@ -116,14 +116,7 @@ insert into bmscantest select r, 'fooooooooooooooooooooooooooooooooooooooooooooo
 create index i_bmtest ON bmscantest(a);
 select count(*) from bmscantest where a>1;
 
--- test accumulation of stats for parallel node
 reset enable_seqscan;
-alter table tenk2 set (parallel_workers = 0);
-explain (analyze, timing off, summary off, costs off)
-       select count(*) from tenk1, tenk2 where tenk1.hundred > 1
-        and tenk2.thousand=0;
-alter table tenk2 reset (parallel_workers);
-
 reset enable_indexscan;
 reset enable_hashjoin;
 reset enable_mergejoin;