Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2443#discussion_r155661686
--- 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 --
https://issues.apache.org/jira/browse/STORM-2848---
