We have a requirement to load data every minute from DB table using the scheduler. Not to use the CDC approach. We loaded data and created DataStream using fromCollection. This works well for one time, to have on-going, we followed the scheduler. I am not getting how the scheduling can be enabled for on-going. Does anyone come across such a scenario/requirements? Any suggestions/references/best approach to follow? Thanks