cameronlee314 commented on pull request #1506: URL: https://github.com/apache/samza/pull/1506#issuecomment-871784644
Summarizing some discussion in a different channel: - Even if we updated the `TaskModel` API right now, it wouldn't clean up `InternalTaskContext` because we still have to figure out how to deal with passing around `StreamMetadataCache`. Cleaning up the wiring for `StreamMetadataCache` doesn't seem high on the TODO list, so this `InternalTaskContext` would still be around for a while. - State restore (SEP-28/SEP-29) doesn't plan to update `TaskModel` to add explicit information about side inputs, so the priority on updating `TaskModel` isn't that high. - There are functionality (control message handling) and productivity benefits (testing improvements) that this PR gives, so we will get this in now. https://issues.apache.org/jira/browse/SAMZA-2661 (Add a way to determine which inputs are side inputs in TaskModel) and https://issues.apache.org/jira/browse/SAMZA-2662 (Remove InternalTaskContext hacks for wiring objects to high-level API) have been created for future cleanup. -- 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]
