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 !
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
