Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2355#discussion_r142506999
--- Diff:
storm-client/src/jvm/org/apache/storm/topology/OutputFieldsGetter.java ---
@@ -39,6 +39,9 @@ public void declareStream(String streamId, Fields fields)
{
}
public void declareStream(String streamId, boolean direct, Fields
fields) {
+ if (null == streamId) {
+ throw new IllegalArgumentException("streamId cann't be null");
--- End diff --
Thanks. I made a really silly mistake...
---