Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
It looks like setting task.broadcast.inputs to an empty string logs the following exception:
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]'
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.
Attachments
Issue Links
- links to