[ 
https://issues.apache.org/jira/browse/SAMZA-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574237#comment-16574237
 ] 

Abhishek Shivanna commented on SAMZA-1806:
------------------------------------------

Fix: https://github.com/apache/samza/pull/604

> 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
>            Priority: Minor
>
> 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