https://medium.com/@tspann/ingesting-events-into-dockerized-ibm-db2-jdbc-with-apache-nifi-f0ca452d1351   It works fine with QueryDatabaseTableRecord and PutDatabaseRecord ... View more

Tracking here: https://issues.apache.org/jira/browse/NIFI-11682 ... View more

https://dev.to/tspannhw/simple-change-data-capture-cdc-with-sql-selects-via-apache-nifi-flank-19m4   You can use the metadata database processors to list all tables in a database and then read all values from tables   ... View more

@NaBeeL_NaQeeBi Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future. Thanks. ... View more

everybody is entitled to an opinion but may I ask why are you saying this? 🙂 As you are on a NiFi post, I assume that you are referring to the Cloudera NiFi documentation? I find it very helpful, especially combined with the NiFi's original documentation. It even has some additional thins compared to the original documentation. No matter the feedback, positive or negative, it is good when you know what to do with it. In your case, if you would provide a better and more structured feedback, maybe somebody from Cloudera would understand your point of view and he/she could modify the documentation 🙂 ... View more

@mburgess @SamCloud  convert jsontosql is giving SQL but with '?' marks. example: "DELETE FROM tab1 WHERE id = ? AND feature_name = ? AND state = ? AND tenant_id = ?" When i print via putfile, the json has valid values..  [{"id":1,"feature_name":"fet1","state":16,"tenant_id":"abc123"}] Want to understand where I am doing it wrong.. Please help ... View more

Yes this is best approach, Inserting all in staging table and then using merge to insert/update on target table, Just need to truncate staging table for next round of inserts.  ... View more

@Griggsy, Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future.  ... View more

@mburgess I have the same problem. The code was written in jython.   from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import OutputStreamCallback from java.lang import Object # Define a subclass of OutputStreamCallback for use in session.write() class PyOutputStreamCallback(OutputStreamCallback):   def __init__(self, cadena):     self.cadena = cadena   def process(self, outputStream):     outputStream.write(bytearray(self.cadena.encode('utf-8'))) # end class flowFile = session.get() if (flowFile != None):     table = flowFile.getAttribute('table_name')         if (table != 'database_1.dbo.dtproperties'):         newFlowFile = session.create(flowFile)         newFFC = ''         newFlowFile = session.write(newFlowFile, PyOutputStreamCallback(newFFC))                 session.transfer(newFlowFile, REL_SUCCESS)             elif (table == 'database_1.dbo.dtproperties'):         session.remove(flowFile)     else:         session.transfer(flowFile, REL_FAILURE)   I'm understanding that flow files are passing one by one, right? So if there is a flow file with an attribute ''database_1.dbo.dtproperties" should be eliminated without affecting other flow files. But I got "flowfile has already marked for removal" ... View more

Hi @gkp_shakeel ,   Can you please help me with the CURSOR data type object and the INTERFACE_DATA%ROWTYPE; Parameters. How can I call such store procedure   ... View more