[
https://issues.apache.org/jira/browse/NIFI-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307995#comment-17307995
]
Marc Parisi commented on NIFI-8283:
-----------------------------------
Thanks for this patch! My apologies, this fell off my radar [~kzsihovszki] ,
but I wrote a follow on change in my personal branch to add this as an option
and forgot to commit.
In my use cases I don't use values, but of course that should have been
returned. In my branch I added an option to return the values by default, but
disable entering them into the schema if chosen to do so. Would that be
possible to add in this PR? Thanks!
> 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
> Priority: Major
> Attachments: Screenshot 2021-03-02 at 12.53.58.png, scanned.avro
>
> Time Spent: 1.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)
