Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
Description
val t = CollectionDataSets.get3TupleDataSet(env).as('a, 'b, 'c) .where(Literal(false)) .groupBy('b) .select('a.sum)
With PruneEmptyRules instances enabled, we expect the empty Aggregate and Project should be removed, while it's not removed after logical optimization.
Attachments
Issue Links
- relates to
-
FLINK-3508 Add more test cases to verify the rules of logical plan optimization
- Closed