Github user srdo commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2443#discussion_r155647898
  
    --- Diff: 
sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/CompilerUtil.java ---
    @@ -117,9 +138,21 @@ public TableBuilderInfo parallelismHint(int 
parallelismHint) {
           return this;
         }
     
    +    // FIXME: we may want to separate Stream and Table, and let output 
table be Table instead of Stream
    --- End diff --
    
    Thanks


---

Reply via email to