Github user srdo commented on a diff in the pull request: https://github.com/apache/storm/pull/2443#discussion_r202650461 --- Diff: sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/StreamsStormRuleSets.java --- @@ -72,13 +72,13 @@ // merge and push unions rules UnionEliminatorRule.INSTANCE, - TridentScanRule.INSTANCE, - TridentFilterRule.INSTANCE, - TridentProjectRule.INSTANCE, - TridentAggregateRule.INSTANCE, - TridentJoinRule.INSTANCE, - TridentModifyRule.INSTANCE, - TridentCalcRule.INSTANCE + StreamsScanRule.INSTANCE, + StreamsFilterRule.INSTANCE, + StreamsProjectRule.INSTANCE, + StreamsAggregateRule.INSTANCE, --- End diff -- Makes sense.
---