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.


---

Reply via email to