Member since
06-14-2022
58
Posts
0
Kudos Received
0
Solutions
09-27-2022
04:31 AM
Hi @neeraj_sha , have you implemented this requirement, if so can you please share your solution?
... View more
09-21-2022
08:13 PM
Hi All, I am trying to call store procedure using groovy script and the processor I am using is Execute Script (using groovy because i want to capture the response of store procedure). But the flow files are getting stuck and when I am restarting the processor it's getting passed The same code I am using on other environment it's working fine without an issue. Below is code I am using to call the store procedure: import org.apache.commons.io.IOUtils import org.apache.nifi.controller.ControllerService import org.apache.nifi.processor.io.StreamCallback import java.nio.charset.* import groovy.sql.OutParameter import groovy.sql.Sql import java.sql.ResultSet import java.sql.Clob try{ def lookup = context.controllerServiceLookup def dbServiceName = ConncationPool.value def dbcpServiceId = lookup.getControllerServiceIdentifiers(ControllerService).find { cs -> lookup.getControllerServiceName(cs) == dbServiceName } def conn = lookup.getControllerService(dbcpServiceId).getConnection(); sql = Sql.newInstance(conn); def flowFile = session.get() if(!flowFile) return attr1= flowFile.getAttribute('attr1') attr2= flowFile.getAttribute('attr2') attr3= flowFile.getAttribute('attr3') def data = [] String sqlString ="""{call procedure_name(?,?,?,?)}"""; def OUT_JSON def parametersList = [attr1,attr2,attr3,Sql.VARCHAR]; sql.call(sqlString, parametersList) {out_json_response -> OUT_JSON = out_json_response }; def attrMap = ['out_json_response':String.valueOf(OUT_JSON),'Conn':String.valueOf(conn)] flowFile = session.putAllAttributes(flowFile, attrMap) conn.close() sql.close(); session.transfer(flowFile, REL_SUCCESS) } catch (e){ if (conn != null) conn.close(); if (sql != null) sql.close(); log.error('Scripting error', e) flowFile = session.putAttribute(flowFile, "error", e.getMessage()) session.transfer(flowFile, REL_FAILURE) } finally { if (conn != null) conn.close(); if (sql != null) sql.close(); } Can you please help me to solve the issue. Is anyone face the same issue?
... View more
Labels:
- Labels:
-
Apache NiFi
06-21-2022
03:55 AM
Hi Can tell me what is package and body
... View more
06-21-2022
03:50 AM
Can you please tell me how it worked for you?
... View more
06-21-2022
03:20 AM
Hi All, Can you please help me.
... View more
06-21-2022
01:50 AM
I need to use ORACLE stored procedure with input PARAM and this input PARAM is coming from flow file and get output from that stored procedure. is any processor is available with run stored procedure and return the out put in AVRO schema or any other format? Please help me.
... View more
Labels:
- Labels:
-
Apache NiFi
06-20-2022
09:39 AM
Hi @SAMSAL , i did same configuration but my processor is stuck. am I doing something wrong? the error I am getting is: Cannot create PoolableConnectionFactory (IO Error: The Network Adapter could not establish the connection)
- Caused by: java.sql.SQLException: Cannot create PoolableConnectionFactory (IO Error: The Network Adapter could not establish the connection)
- Caused by: java.sql.SQLRecoverableException: IO Error: The Network Adapter could not establish the connection
- Caused by: oracle.net.ns.NetException: The Network Adapter could not establish the connection
... View more
06-20-2022
08:12 AM
Hi, I am new to NiFi, I wanted to understand the how can we connect to the oracle database through NiFi?Do we need to download the driver for the same and paste it to NiFi server ? or we have to install the database on the same server and after using that driver then only we can connect to the database. Please help me.
... View more
Labels:
- Labels:
-
Apache NiFi
06-15-2022
02:16 AM
Hi @ask_bill_brooks , I checked everything, in node1 log I am getting "2022-06-15 11:46:36,041 WARN [main] o.a.nifi.controller.StandardFlowService Failed to connect to cluster due to: org.apache.nifi.cluster.protocol.ProtocolException: Failed marshalling 'CONNECTION_REQUEST' protocol message due to: javax.net.ssl.SSLHandshakeException: PKIX path validation failed: java.security.cert.CertPathValidatorException: Path does not chain with any of the trust anchors" and in node3 I can't see any error, exception....Can you please help me with this. What should I check?
... View more
06-15-2022
12:52 AM
Hi, I need help. I have successfully installed NiFi on Cooperates Linux Machine. But while accessing this NiFi server getting "This site can’t be reached" error. We checked everything but still persisting the issue. Please help me.
... View more
Labels:
- Labels:
-
Apache NiFi
- « Previous
- Next »