Hello Team, Purging of the Checkpoints is done in Stram. Why not do that from the StreamingContainers?
Committed window information is already available in StreamingContainers and it will also distribute the computation across the containers. Corner cases can still be handled in Stram. Example: Dynamic partitioning. Thanks
