@Iwantkakao  There are 2 things i see right off bat:   Tue Jan 31 19:47:13 UTC 2023 WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification. ^^ consider the recommendation:   useSSL=false in your sqoop command.   23/01/31 19:47:14 ERROR manager.SqlManager: Error executing statement: java.sql.SQLException: Access denied for user ''@'localhost' (using password: NO) java.sql.SQLException: Access denied for user ''@'localhost' (using password: NO) ^^ this error is saying that your user does not have access to mysql.  You are going to need to provide a specific user, password, and host, with permissions and grants accordingly.   If your user is root, add the username and password to the command.       Last but not least, sqoop project is now "in the attic" which means the project is no longer actively getting support and developement from the open source community.   I recommend that you learn other techniques to complete the same outcome.     ... View more

@samrathal Per the docs you need to provide the ID:   Request consumes: */*   Name Location Type Description id path string The connection id. flowfile-uuid path string The flowfile uuid. clusterNodeId query string The id of the node where the content exists if clustered. You should be getting that ID from the previous get call ( Gets a FlowFile from a Connection ) within the response is an object:  FlowFileEntity   Inside is the  "clusterNodeId"  corresponding to which node that flowfile exists on.   { "flowFile": { "uri": "value" , "uuid": "value" , "filename": "value" , "position": 0 , "size": 0 , "queuedDuration": 0 , "lineageDuration": 0 , "penaltyExpiresIn": 0 , "clusterNodeId": "value" , "clusterNodeAddress": "value" , "attributes": { "name": "value" } , "contentClaimSection": "value" , "contentClaimContainer": "value" , "contentClaimIdentifier": "value" , "contentClaimOffset": 0 , "contentClaimFileSize": "value" , "contentClaimFileSizeBytes": 0 , "penalized": true } }  Those details are exposed in the nifi api doc, just be sure to click into the entity. ... View more