[jira] [Created] (NIFI-8283) Value handling in ScanAccumulo processor

["Zsihovszki Krisztina (Jira)" <ji...@apache.org>]

Zsihovszki Krisztina created NIFI-8283:
------------------------------------------

             Summary: Value handling in ScanAccumulo processor
                 Key: NIFI-8283
                 URL: https://issues.apache.org/jira/browse/NIFI-8283
             Project: Apache NiFi
          Issue Type: Bug
          Components: Extensions
    Affects Versions: 1.11.4, 1.11.3, 1.11.2, 1.11.1, 1.11.0
            Reporter: Zsihovszki Krisztina
         Attachments: Screenshot 2021-03-02 at 12.53.58.png, scanned.avro

ScanAccumuloRecord processor does not return the value, just the keys.

If I add the record with the Accumulo Java client or via accumulo shell command
("insert row1 cf1 cq1 value1"), the record looks like this in the table:

2021-03-02 11:29:22,765 [Shell.audit] INFO : root@accumulo nifiTable> scan
row0 cf0:cq0 []    *value0*

The "value0" is not returned when I run ScanAccumulo processor.
The scanned record (converted from avro) looks like this:

{"row": "row0", "columnFamily": "cf0", "columnQualifier": "cq0", "columnVisibility": "", "timestamp": 1614684537363}

The avro file does not seem to be containing the values either (please a scanned avro file attached).

I don't see the inserting the value in the [code|https://github.com/apache/nifi/blob/f9ae3bb9c970cd8d6d1d9e10f07cab9bdb66baa9/nifi-nar-bundles/nifi-accumulo-bundle/nifi-accumulo-processors/src/main/java/org/apache/nifi/accumulo/processors/ScanAccumulo.java#L274] either.

I did not specify any schema when used ConvertAvroToJSON processor, by default it uses the schema defined in the avro file. 

 Please find the ScanAccumulo processor settings in attachment.




--
This message was sent by Atlassian Jira
(v8.3.4#803005)