Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/2443#discussion_r155644012 --- 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 -- OK I'll file an issue and remove the comment.
---