You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Koji Kawamura (JIRA)" <ji...@apache.org> on 2017/12/04 03:16:01 UTC

[jira] [Created] (NIFI-4654) RAW S2S transit URI should contain Port ID instead of FlowFile ID

Koji Kawamura created NIFI-4654:
-----------------------------------

             Summary: RAW S2S transit URI should contain Port ID instead of FlowFile ID
                 Key: NIFI-4654
                 URL: https://issues.apache.org/jira/browse/NIFI-4654
             Project: Apache NiFi
          Issue Type: Improvement
          Components: Core Framework
            Reporter: Koji Kawamura
            Assignee: Koji Kawamura


In order to track where a FlowFile is sent to or received from, a provenance event record has to have target RemoteGroupPort ID (if it's S2S client) or RootGroupPort ID (if it's S2S server) in it.

RemoteGroupPort used to have its component UUID as the same UUID as corresponding RootGroupPort's, but NIFI-3155 changed each RemoteGroupPort instance to have different UUIDs.

HTTP protocol still contains port uuid in transit URI. But RAW does not contain a port identifier neither in transit URI nor provenance event record any longer. 

Currently, each S2S protocol generates provenance event with transit URI as follows:

* RAW
** nifi://remote-host:remote-port/flowfile-uuid
** E.g. nifi://nifi1.example.com:8081/cb729f05-b2ee-4488-909d-c6696cc34588
* HTTP
** http(s)://homote-host:remote-port/nifi-api/data-transfer/in|output-ports/portId/transactions/txId/flow-files
** E.g. http://nifi1.example.coml:8080/nifi-api/data-transfer/input-ports/35dbc0ab-015e-1000-144c-a8d71255027d/transactions/89335043-f105-4de7-a0ef-46f2ef0c7c51/flow-files

Also provenance events created when a FlowFile is received from remotely have 'Source FlowFile Id' field which contains FlowFile UUID in remote instance.

This JIRA changes RAW S2S protocol to embed Port ID instead of FlowFile ID (which is available in Source FlowFile Id if needed).






--
This message was sent by Atlassian JIRA
(v6.4.14#64029)