I'm trying to copy the data from one database(MySQL) to another database(MySQL). Below is the flow.
GenerateTableFetch Partition Size : 1500 records. Total 3200 records so it's creating 3 files as shown in the picture.
I'm able to read the data from the source database(avro format) and convert the data to json(using AvrotoJSON processor). Now I'm trying to load the JSON data into MySQL table using ConvertJSONTOSQL Pricessor. In the source table I have 3200
records, however in my destination table I'm getting 10000+ records. I didn't get where I did mis configuration so that it's inserting duplicate records into destination table. Below are screenshots of the individual processors.
Any suggestions please.