Check all TestUnion plans fully distributed
@@ -54,6 +54,7 @@ public class TestUnion
LogicalPlanner.Stage.OPTIMIZED_AND_VALIDATED,
false);
assertAtMostOneAggregationBetweenRemoteExchanges(plan);
+ assertPlanIsFullyDistributed(plan);
}
@Test
@@ -64,6 +65,7 @@ public class TestUnion
LogicalPlanner.Stage.OPTIMIZED_AND_VALIDATED,
false);
assertAtMostOneAggregationBetweenRemoteExchanges(plan);
+ assertPlanIsFullyDistributed(plan);
}
@Test
