Abhishek Shivanna created SAMZA-1806:
----------------------------------------

             Summary: Configuring task.broadcast.inputs to an empty string 
raises IllegalArgumentException
                 Key: SAMZA-1806
                 URL: https://issues.apache.org/jira/browse/SAMZA-1806
             Project: Samza
          Issue Type: Bug
            Reporter: Abhishek Shivanna


It looks like setting *task.broadcast.inputs* to an empty string logs the 
following exception:
{noformat}
Exception in thread "main" java.lang.IllegalArgumentException: incorrect format 
in . Broadcast stream names should be in the form 'system.stream#partitionId' 
or 'system.stream#[partitionN-partitionM]'

{noformat}
The problem stems from the fact that when *task.broadcast.inputs* is set to 
*"",* the call to the getList function in 
TaskConfigJava:getBroadcastSystemStreamPartitions() returns a List<String> one 
element (an empty string)  and causes the exception to be raised.

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to