No matches were found for subject:"How to prevent and track data loss\/dropped due to watermark during structure streaming aggregation"