lakshmi-manasa-g opened a new pull request, #1610: URL: https://github.com/apache/samza/pull/1610
**Symptom:** Watermark and end of stream message can throws org.apache.samza.SamzaException: SystemStreamPartition [systemA, streamB, 1, 0] is not registered! **Cause:** TaskInstance uses the IncomingMessageEnvelope.getSSP(elasticityFactor) which gives an SSP with keyBucket and this SSP w/ keyBucket should be present in the task’s list of ssp consumed for it to process. But for watermark and end of stream, RunLoop routes them to all tasks consuming their ssp irrespective of the key bucket (for correctness of watermark and end of stream handling). **Changes:** udpated TaskInstance to check if the incoming message is watermark or end of stream and accept it for processing if ssp matches without key bucket **Tests:** added new tests **API Changes:** no public API changes **Upgrade/usage instructions:** None **Backwards compatible:** yes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
