dnishimura opened a new pull request #928: SAMZA-1990: Samza framework should let using the same system stream as both input and output. URL: https://github.com/apache/samza/pull/928 **Symptom:** An `IllegalArgumentException` is thrown when the same `streamId` is referred from multiple input/output stream descriptors. **Cause:** The `ApplicationDescriptorImpl` caches the serde instances for streams by a `streamId` and there's a check to ensure the expected stream serde matches when using the same stream from multiple input/output descriptors. However the check is incorrect because it compares serde instances and not serde types. This check always fails in this scenario. **Fix:** Compare the stream serdes for a particular `streamId` by type. Please take a look @prateekm @nickpan47 CC: @atoomula
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
