US11544133B2 - System and Method for Dynamic Log Management of Stream Processing in a Distributed Environment