question putDatabaseRecord really slow in Support Questions

putDatabaseRecord really slow

LiranJP — Wed, 06 Mar 2024 14:10:04 GMT

Hi there,

I am experiencing really slow ingestion with putDatabaseRecord process.
The flow is simple - query data from mySQL 5.6 and ingesting it into redshift.
Currently im just testing it so I list only specific tables from those 2 databases and then I query 'select * from $db.tablename' - but the ingestion using putDatabaseRecord is terribly slow (100 rows 5min).
I am using AvroReader inside putDatabaseRecord but didnt make any changes to the avroreader - I just make sure flow files be small (100 rows).
Does AvroReader split the 100 rows into 100 SQL statements?
How do I fix this to have better performance?

Re: putDatabaseRecord really slow

DianaTorres — Wed, 06 Mar 2024 17:05:54 GMT

@LiranJP Welcome to the Cloudera Community!

To help you get the best possible solution, I have tagged our NiFi experts @mburgess @MattWho who may be able to assist you further.

Please keep us updated on your post, and we hope you find a satisfactory solution to your query.

Re: putDatabaseRecord really slow

mburgess — Wed, 06 Mar 2024 21:07:17 GMT

How is your DBCPConnectionPool configured?

Re: putDatabaseRecord really slow

LiranJP — Thu, 07 Mar 2024 08:46:09 GMT

That's the redshift connection:

That's the mySQL connection:

I do understand that INSERTs on redshift might be slow and that's why people are using COPY command but 100 rows in 5min is weird.
I know that for BigQuery for example there's a dedicated processor in order to load data but couldn't find anything for RedShift so that's why I am using putDatabaseRecord.

Edit - After I loaded 100 rows I exported the same 100 rows into an INSERT SQL statement and run it directly on the redshift, this task took 1.1 second.
Edit2 - Since im the kind of guy that loves doing my job and to find solution I found this -
reWriteBatchedInserts=true;reWriteBatchedInsertsSize=102400;
I found this on some reddit post by chance, this is working way better now but I couldn't find some details regard those parameters to make them optimized and still that's not the best (still little bit slow).

I am not sure that's the solution so i'm still waiting for your input as well.
Also, if I would like to change it to drop the Avro/flow files into S3 and then execute COPY command from NIFI is it possible?

Re: putDatabaseRecord really slow

LiranJP — Sun, 10 Mar 2024 07:10:29 GMT

@mburgess Any update from your side?