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


---

Reply via email to