Shanthoosh Venkataraman created SAMZA-1529:
----------------------------------------------

             Summary: Improve error handling in 
RangeSystemStreamPartitionMatcher
                 Key: SAMZA-1529
                 URL: https://issues.apache.org/jira/browse/SAMZA-1529
             Project: Samza
          Issue Type: Bug
            Reporter: Shanthoosh Venkataraman
            Priority: Minor


With the existing RangeSystemStreamPartitionMatcher implementation, when 
invalid partitionId range is set in configuration(For instance, partitionRange 
= greater than all partitionCount in all inputStreams), all the ssps will get 
filtered.

It'll be better to fail at the Matcher layer with error when result sspSubset 
is empty after applying the filter(rather than failing somewhere down the line 
in jobModelGenertion).



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to