You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Pierre Villard (Jira)" <ji...@apache.org> on 2021/03/25 12:02:00 UTC

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

     [ https://issues.apache.org/jira/browse/NIFI-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Pierre Villard resolved NIFI-8283.
----------------------------------
    Fix Version/s: 1.14.0
         Assignee: Timea Barna
       Resolution: Fixed

> 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.0, 1.11.1, 1.11.2, 1.11.3, 1.11.4
>            Reporter: Zsihovszki Krisztina
>            Assignee: Timea Barna
>            Priority: Major
>             Fix For: 1.14.0
>
>         Attachments: Screenshot 2021-03-02 at 12.53.58.png, scanned.avro
>
>          Time Spent: 2.5h
>  Remaining Estimate: 0h
>
> 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)