Re: Beam/Samza Ensuring At Least Once semantics

2019-07-11 Thread Deshpande, Omkar
Yes, we are resuming from samza’s last commit. But the problem is that the last commit was done for data in the window that is not completely processed. From: Lukasz Cwik Date: Wednesday, July 10, 2019 at 11:07 AM To: dev Cc: "LeVeck, Matt" , "Deshpande, Omkar" , Xinyu Liu , Xinyu Liu , Samar

Draft July report for Samza

2019-07-11 Thread Yi Pan
Hi, all, Here is the draft report I had for Samza this quarter. Please let me know if I miss anything. Thanks! ## Description: - Apache Samza is a distributed stream processing engine that are highly configurable to process events from various data sources, including real-time messaging syst