Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

I am trying to insert CSV files into MYSQL database using NIFI. So My flow is GetFile --> UpdateAttribute --> PutDatabaseRecord. Facing issue with PutDatabaserecord processor

Highlighted

I am trying to insert CSV files into MYSQL database using NIFI. So My flow is GetFile --> UpdateAttribute --> PutDatabaseRecord. Facing issue with PutDatabaserecord processor

New Contributor

In putDatabaseRecord , I have configured as connection pulling service and have set jdbc:mysql://X.Y.Z.W:3306/test_db as connection string. When I am trying to run entire flow, I am getting error like "hive.test table does not exist". In my mysql instance, I have hive as database. I have given test_db in connection string then why it's checking in other databases i.e here hive?


Have a look into my flow attached.


putdbrecord.pngflow.pngdbcpconnectionpool.png