bkonold opened a new pull request #1419:
URL: https://github.com/apache/samza/pull/1419
**Feature:** Consumption of standby side inputs must honor checkpointed
changelog offsets, else customers using standby containers cannot enable
transactional state.
**Changes:** Adds a thread to ContainerStorageManager to continually poll
the checkpoint topic, as well as barrier conditions within TaskSideInputHandler
to keep consumption of standby side inputs from continuing past the
checkpointed offset.
**Tests:** No tests. TODO.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
