diff --git a/src/backend/executor/execParallel.c b/src/backend/executor/execParallel.c index e9337a97d17..c8f3300ec00 100644 --- a/src/backend/executor/execParallel.c +++ b/src/backend/executor/execParallel.c @@ -977,14 +977,14 @@ ExecParallelReInitializeDSM(PlanState *planstate, ExecSeqScanReInitializeDSM((SeqScanState *) planstate, pcxt); break; + + /* The parallel_aware is always true for IndexScan, IndexOnlyScan */ case T_IndexScanState: - if (planstate->plan->parallel_aware) - ExecIndexScanReInitializeDSM((IndexScanState *) planstate, + ExecIndexScanReInitializeDSM((IndexScanState *) planstate, pcxt); break; case T_IndexOnlyScanState: - if (planstate->plan->parallel_aware) - ExecIndexOnlyScanReInitializeDSM((IndexOnlyScanState *) planstate, + ExecIndexOnlyScanReInitializeDSM((IndexOnlyScanState *) planstate, pcxt); break; case T_ForeignScanState: