index 0a519fae313cc6ec532b522486adaff48a38fbf6..04eb3650aa3df37a9f74320bbdd6f7bbd1cc42b1 100644 (file)
ExecParallelHashTableInsert(hashtable, slot, hashvalue);
hashtable->partialTuples++;
}
- BarrierDetach(&pstate->grow_buckets_barrier);
- BarrierDetach(&pstate->grow_batches_barrier);
/*
* Make sure that any tuples we wrote to disk are visible to
*/
ExecParallelHashMergeCounters(hashtable);
+ BarrierDetach(&pstate->grow_buckets_barrier);
+ BarrierDetach(&pstate->grow_batches_barrier);
+
/*
* Wait for everyone to finish building and flushing files and
* counters.