Member since
04-13-2023
3
Posts
0
Kudos Received
0
Solutions
04-14-2023
07:03 AM
I have also tested the same with Apache Nifi 1.15.3 (open-source/community) and it works. It did not work though when testing with Apache Nifi 1.13.2 (open-source/community) it still fails with the same error message.
... View more
04-14-2023
04:51 AM
Hi @cotopaul, Thanks for your prompt reply, it was clear and to the point. I have followed the same steps and it works for Apache Nifi 1.18.0 (open-source/community). The version I have observed the issue on is Apache Nifi 1.11.4 (open-source/community).
... View more
04-13-2023
05:54 AM
I am using ExecuteSQL Nifi processor to read from a Postgresql table defined as per below: CREATE TABLE otherdatatype( column1 int, column2 varchar(255), column3 bytea ); I get the values of that table successfully, as per below: column1 : 1 column2 : "hello world" column3 : \x4920616d206261636b20616761696e2e2e2e (converted to text "I am back again...") and the AVRO schema automatically generated by ExecuteSQL Nifi processor is: { "type": "record", "name": "otherdatatype", "namespace": "any.data", "fields": [{ "name": "column1", "type": ["null", "int"] }, { "name": "column2", "type": ["null", "string"] }, { "name": "column3", "type": ["null", "bytes"] }] } Then I try to use PutDatabaseRecord Nifi processor to insert the values already read into another table, as per below: The AvroReaderInferSchema record reader property is set to an AvroReader controller that is using the embedded Avro Schema: Then execution fails, the flowfile is placed in the failure queue and the below value is provided in the relevant error attribute : putdatabaserecord.error : Cannot cast an instance of [Ljava.lang.Object; to type Types.ARRAY Any ideas what the issue here is? Am I doing something wrong? Is it a bug with PutDatabaseRecord processor? Is there any other alternative (other processor or other controller)?
... View more
Labels:
- Labels:
-
Apache NiFi