This change was done as part of adding delete API support : https://github.com/apache/incubator-hudi/commit/7031445eb3cae5a4557786c7eb080944320609aa I don't remember the reason behind this. Sivabalan, Can you explain the reason when you get a chance. Thanks,Balaji.V On Wednesday, February 26, 2020, 06:03:53 AM PST, Pratyaksh Sharma <pratyaks...@gmail.com> wrote: Anybody got a chance to look at this?
On Mon, Feb 24, 2020 at 1:04 AM Pratyaksh Sharma <pratyaks...@gmail.com> wrote: > 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 > . > >
