jnioche commented on PR #9175: URL: https://github.com/apache/storm/pull/9175#issuecomment-6336653353
Thanks @ErnestasVaiciukeviciusAdform and reviewers. Looks good! **Suggestions** 1. **Share the upstream-task logic.** `WorkerState.computeOutboundTasks` and `Executor.computeUpstreamTaskIds` now repeat the same source filtering. If one changes without the other, the routes and the feedback targets drift apart and the warnings come back. A shared static helper would prevent that. 2. **Add a test for the sink-only case.** Assert `hasRemoteOutboundTasks()` is true for a worker hosting only a sink bolt, with feedback on and acking off. That's the case with real impact, and nothing tests it today. -- 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]
