[ 
https://issues.apache.org/jira/browse/NIFI-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538822#comment-16538822
 ] 

ASF subversion and git services commented on NIFI-4654:
-------------------------------------------------------

Commit e94f0757db617c649ae054d7c914feade9e1185e in nifi's branch 
refs/heads/master from [~ijokarumawak]
[ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=e94f075 ]

NIFI-4654: Support reporting RAS S2S lineage to Atlas

- Added 's2s.port.id' FlowFile attribute to track target remote Port id
- Use 's2s.port.id' to analyze RAW S2S provenance events
- This closes #2863


> 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
>            Priority: Major
>
> 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
(v7.6.3#76005)

Reply via email to