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...
---