nifi-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "David Mollitor (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (NIFI-6406) ForkRecord Extract Incorrectly Forks Records
Date Fri, 28 Jun 2019 18:03:00 GMT

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

David Mollitor updated NIFI-6406:
---------------------------------
    Summary: ForkRecord Extract Incorrectly Forks Records  (was: ForkReader Extract Not Working
As Advertised)

> ForkRecord Extract Incorrectly Forks Records
> --------------------------------------------
>
>                 Key: NIFI-6406
>                 URL: https://issues.apache.org/jira/browse/NIFI-6406
>             Project: Apache NiFi
>          Issue Type: Improvement
>          Components: Core Framework
>    Affects Versions: 1.9.2
>            Reporter: David Mollitor
>            Priority: Major
>
> I am looking at the {{ForkRecord}} processor and trying to reproduce the example provided
here:
> [https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.9.2/org.apache.nifi.processors.standard.ForkRecord/additionalDetails.html]
> In particular, I am looking at _Example 2 - Extracting with parent fields_
> My input:
> {code}
> [{
>         "id": 1,
>         "name": "John Doe",
>         "address": "123 My Street",
>         "city": "My City",
>         "state": "MS",
>         "zipCode": "11111",
>         "country": "USA",
>         "accounts": [{
>                 "id": 42,
>                 "balance": 4750.89
>         }, {
>                 "id": 43,
>                 "balance": 48212.38
>         }]
> },
> {
>         "id": 2,
>         "name": "Jane Doe",
>         "address": "345 My Street",
>         "city": "Her City",
>         "state": "NY",
>         "zipCode": "22222",
>         "country": "USA",
>         "accounts": [{
>                 "id": 45,
>                 "balance": 6578.45
>         }, {
>                 "id": 46,
>                 "balance": 34567.21
>         }]
> }]
> {code}
> My output:
> {code}
> [ {
>   "id" : 42,
>   "name" : "John Doe",
>   "address" : "123 My Street",
>   "city" : "My City",
>   "state" : "MS",
>   "zipCode" : "11111",
>   "country" : "USA",
>   "accounts" : [ {
>     "id" : 42,
>     "balance" : 4750.89
>   }, {
>     "id" : 43,
>     "balance" : 48212.38
>   } ]
> }, {
>   "id" : 43,
>   "name" : "John Doe",
>   "address" : "123 My Street",
>   "city" : "My City",
>   "state" : "MS",
>   "zipCode" : "11111",
>   "country" : "USA",
>   "accounts" : [ {
>     "id" : 42,
>     "balance" : 4750.89
>   }, {
>     "id" : 43,
>     "balance" : 48212.38
>   } ]
> }, {
>   "id" : 45,
>   "name" : "Jane Doe",
>   "address" : "345 My Street",
>   "city" : "Her City",
>   "state" : "NY",
>   "zipCode" : "22222",
>   "country" : "USA",
>   "accounts" : [ {
>     "id" : 45,
>     "balance" : 6578.45
>   }, {
>     "id" : 46,
>     "balance" : 34567.21
>   } ]
> }, {
>   "id" : 46,
>   "name" : "Jane Doe",
>   "address" : "345 My Street",
>   "city" : "Her City",
>   "state" : "NY",
>   "zipCode" : "22222",
>   "country" : "USA",
>   "accounts" : [ {
>     "id" : 45,
>     "balance" : 6578.45
>   }, {
>     "id" : 46,
>     "balance" : 34567.21
>   } ]
> } ]
> {code}
> I expect there to be 4 records (2x2) and there are,... but each record caries all of
the fields instead of extracting them (see the output example in the docs).  It looks more
like a cross-join than anything.
> The 'split' function worked as expected.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message