Hi, While working on one of my PRs, I am stuck with the following test cases in TestHoodieDeltaStreamer - 1. testUpsertsCOWContinuousMode 2. testUpsertsMORContinuousMode
For both of them, at line [1] and [2], we are adding 200 to totalRecords while asserting record count and distance count respectively. I am unable to understand what do these 200 records correspond to. Any leads are appreciated. I feel probably I am missing some piece of code where I need to do changes for the above tests to pass. [1] https://github.com/apache/incubator-hudi/blob/078d4825d909b2c469398f31c97d2290687321a8/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java#L425 . [2] https://github.com/apache/incubator-hudi/blob/078d4825d909b2c469398f31c97d2290687321a8/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java#L426 .
