data-integrations/change-data-capture

Data loss in CTInputDStream

zhaber opened this issue · 0 comments

getChangeData method of CTInputDStream assumes that prev < cur which is not true right after cleanup of the change tracking table. SQL Server maintenance can remove tracking information and reset CHANGE_TRACKING_CURRENT_VERSION to 0. The caller of getChangeData either should invoke the method twice in this case - once with an open upper bound and once with an open lower bound or fail the pipeline.