diff -w -U3 C:/cirrus/src/test/regress/expected/subselect.out C:/cirrus/build/testrun/recovery/027_stream_regress/data/results/subselect.out
--- C:/cirrus/src/test/regress/expected/subselect.out	2024-02-20 01:13:24.940222100 +0000
+++ C:/cirrus/build/testrun/recovery/027_stream_regress/data/results/subselect.out	2024-02-20 01:18:06.647188100 +0000
@@ -2016,16 +2016,16 @@
                    QUERY PLAN                    
 -------------------------------------------------
  Hash Join
-   Hash Cond: (c.odd = b.odd)
+   Hash Cond: (c.hundred = a.hundred)
    ->  Hash Join
-         Hash Cond: (a.hundred = c.hundred)
-         ->  Seq Scan on tenk1 a
+         Hash Cond: (b.odd = c.odd)
+         ->  Seq Scan on tenk2 b
          ->  Hash
                ->  HashAggregate
                      Group Key: c.odd, c.hundred
                      ->  Seq Scan on tenk2 c
    ->  Hash
-         ->  Seq Scan on tenk2 b
+         ->  Seq Scan on tenk1 a
 (11 rows)
 
 -- we can pull up the aggregate sublink into RHS of a left join.
diff -w -U3 C:/cirrus/src/test/regress/expected/select_parallel.out C:/cirrus/build/testrun/recovery/027_stream_regress/data/results/select_parallel.out
--- C:/cirrus/src/test/regress/expected/select_parallel.out	2024-02-20 01:13:24.931459200 +0000
+++ C:/cirrus/build/testrun/recovery/027_stream_regress/data/results/select_parallel.out	2024-02-20 01:18:54.112998600 +0000
@@ -452,25 +452,35 @@
   where tenk1.four = t.four
 );
                                                                                                                           QUERY PLAN                                                                                                                           
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
- Seq Scan on public.tenk1 t
+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
+ Hash Join
    Output: t.unique1, t.unique2, t.two, t.four, t.ten, t.twenty, t.hundred, t.thousand, t.twothousand, t.fivethous, t.tenthous, t.odd, t.even, t.stringu1, t.stringu2, t.string4
-   Filter: (SubPlan 1)
-   SubPlan 1
-     ->  Hash Join
-           Output: t.two
-           Hash Cond: (tenk1.stringu1 = t3.stringu1)
-           ->  Seq Scan on public.tenk1
-                 Output: tenk1.unique1, tenk1.unique2, tenk1.two, tenk1.four, tenk1.ten, tenk1.twenty, tenk1.hundred, tenk1.thousand, tenk1.twothousand, tenk1.fivethous, tenk1.tenthous, tenk1.odd, tenk1.even, tenk1.stringu1, tenk1.stringu2, tenk1.string4
-                 Filter: (tenk1.four = t.four)
+   Inner Unique: true
+   Hash Cond: (t.four = tenk1.four)
+   ->  Gather
+         Output: t.unique1, t.unique2, t.two, t.four, t.ten, t.twenty, t.hundred, t.thousand, t.twothousand, t.fivethous, t.tenthous, t.odd, t.even, t.stringu1, t.stringu2, t.string4
+         Workers Planned: 4
+         ->  Parallel Seq Scan on public.tenk1 t
+               Output: t.unique1, t.unique2, t.two, t.four, t.ten, t.twenty, t.hundred, t.thousand, t.twothousand, t.fivethous, t.tenthous, t.odd, t.even, t.stringu1, t.stringu2, t.string4
+               Filter: (t.two IS NOT NULL)
            ->  Hash
-                 Output: t3.stringu1
+         Output: tenk1.four
+         ->  HashAggregate
+               Output: tenk1.four
+               Group Key: tenk1.four
                  ->  Gather
-                       Output: t3.stringu1
+                     Output: tenk1.four
                        Workers Planned: 4
+                     ->  Parallel Hash Join
+                           Output: tenk1.four
+                           Hash Cond: (tenk1.stringu1 = t3.stringu1)
+                           ->  Parallel Seq Scan on public.tenk1
+                                 Output: tenk1.unique1, tenk1.unique2, tenk1.two, tenk1.four, tenk1.ten, tenk1.twenty, tenk1.hundred, tenk1.thousand, tenk1.twothousand, tenk1.fivethous, tenk1.tenthous, tenk1.odd, tenk1.even, tenk1.stringu1, tenk1.stringu2, tenk1.string4
+                           ->  Parallel Hash
+                                 Output: t3.stringu1
                        ->  Parallel Seq Scan on public.tenk1 t3
                              Output: t3.stringu1
-(17 rows)
+(27 rows)
 
 -- this is not parallel-safe due to use of random() within SubLink's testexpr:
 explain (costs off)