[
https://issues.apache.org/jira/browse/NIFI-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436354#comment-15436354
]
ASF GitHub Bot commented on NIFI-2651:
--------------------------------------
Github user ijokarumawak commented on the issue:
https://github.com/apache/nifi/pull/937
I've reviewed the code and done following tests using two NiFi instances A
and B:
- While data are transmitted
- Input port: NiFi A RPG (pushes to) NiFi B input port
- Right click on RPG in NiFi A, then *Disable transmission*
- **ok** RPG stopped immediately. Component shows
TransmissionDisabledException.
- **ok** It may depends on the timing but I saw a
org.eclipse.jetty.io.EofException: Early EOF was thrown on NiFi B.
- **ok** NiFi A and B shows the same number of Sent/Received flow
file count and size (no data loss)
- Right click on input port in NiFi B, then *Stop*
- **ok** RPG shows IOException pipe closed, and remote port is not in
a valid state error. Stopped sending.
- **ok** Input port on NiFi B stopped receiving data immediately.
TransmissionDisabledException was logged.
- **ok** NiFi A and B shows the same number of Sent/Received flow
file count and size (no data loss)
- Output port: NiFi A RPG (pulls from) NiFi B output port
- Right click on RPG in NiFi A, then *Disable transmission*
- **ok** RPG stopped immediately. Component shows
TransmissionDisabledException.
- **ok** It may depends on the timing but I saw a "IOException:
broken pipe" on NiFi B.
- **ok** NiFi A and B shows the same number of Sent/Received flow
file count and size (no data loss)
- Right click on output port in NiFi B, then *Stop*
- **ok** RPG shows IOException pipe closed, and remote port is not in
a valid state error. Stopped receiving.
- **ok** Output port on NiFi B stopped sending data immediately.
TransmissionDisabledException was logged.
- **ok** NiFi A and B shows the same number of Sent/Received flow
file count and size (no data loss)
It works as expected, the RPG stops immediately when it's disabled. I'll
merge it to the master. +1
Thank you @markap14 !
> Remote Process Group does not stop immediately when using HTTP-based
> Site-to-Site
> ---------------------------------------------------------------------------------
>
> Key: NIFI-2651
> URL: https://issues.apache.org/jira/browse/NIFI-2651
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Reporter: Mark Payne
> Assignee: Mark Payne
> Priority: Critical
> Fix For: 1.0.0
>
> Attachments: HTTP_Site-to-Site_with_Large_Data_Chunks.xml
>
>
> If we stop a Remote Process Group that is using the RAW Site-to-Site
> protocol, it stops immediately, interrupting any transaction that is in
> progress. If we stop a Remote Process Group that is using HTTP Site-to-Site
> Protocol, though, the RPG waits until the current transactions have finished.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
