I am running an incremental process for multiple tables where I am using old watermark, new watermark, copy activity, and a stored procedure to update the watermark value. One of my table succeeds when I run the pipeline, for eg I can see total rows copied as 900 whic matches source SQl but when I check in the Database I can see only 70 rows getting reflected, I am not sure why I am not able to see all the rows at database level. Is this some kind of bug in ADF. Need some advise and suggestions on my situation
Thank You
2
Answers
Its not the first time I am seeing this honestly. Can you implement data consistency verification in copy activity? And what is your fault tolerance?
https://learn.microsoft.com/en-us/azure/data-factory/copy-activity-data-consistency
Some rows may be skipped, in this case for example ADF will still show you like they are "written" because logically they are, but physically not, because of incompatible rows etc. which are skipped. In other words, skipped rows are counted as "written" in ADF terminology. Should check that as well
This happens the rows are rejected at the sink.
Do the following to confirm and fix the error.