First backup your flows and settings.   i don't think you can safely upgrade that many versions.   Parameters, records, JSON format and so many other things have come.   I would leave the old one running, backup all flows, run a new clean instance with JDK 11 or 17+ with NiFi 1.23.2 and see what is not working.   https://www.datainmotion.dev/2020/06/no-more-spaghetti-flows.html   See:   https://community.cloudera.com/t5/Support-Questions/Nifi-Upgrade/m-p/346309#M234832 ... View more

Can you upgrade to NiFi 1.23.2?   If not, I would suggest opening a ticket with Cloudera.  This maybe a bug.   I would like to see full nifi logs though and which JDK you are. what language set?    Did the source system change?   https://support.oracle.com/knowledge/Oracle%20Cloud/2925617_1.html nothing in provenance, bulletins or nifi logs/? turn on debugging https://community.cloudera.com/t5/Community-Articles/NiFi-Debugging-Tutorial/ta-p/246082 perhaps a dump of the data, maybe some strange characters in there. ... View more

Could be sensitive column name? a typo somewhere. ... View more

Can you post full error, logs, the sql, table structure.    What version of Oracle? Can you post your full NiFi settings.  is it with all data, perhaps some nulls causing an issue. what is the settings for the Avro reader?   ... View more

What database is that for, that is very weird SQL syntax, why are you making it  JSON to convert to int?   Trying upping the precision from 10 to 14.   Default Decimal Precision ... View more

I wonder if this was fixed 1.23.2.   That seems like it shouldn't be too big, but it may be close.   https://calcite.apache.org/docs/reference.html   INTEGER, INT 4 byte signed integer Range is -2147483648 to 2147483647           try BIGINT ... View more

You need to look at CDC tools like Cloudera Kafka Connect with Debezium or Cloudera SQL Streaming Builder with Debezium.   Kafka Connect https://docs.cloudera.com/runtime/7.2.17/kafka-connect/topics/kafka-connect-connector-debezium-oracle.html   SSB https://docs.cloudera.com/csa/1.10.0/how-to-ssb/topics/csa-ssb-cdc-connectors.html     Or you can do Oracle GoldenGate with Kafka.   I have some examples in this article https://medium.com/cloudera-inc/cdc-not-cat-data-capture-e43713879c03   ... View more

Definitely upgrade to the latest NiFI which is 1.22. ... View more

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