GitHub user jtstorck opened a pull request:
https://github.com/apache/nifi/pull/3010
[WIP] NIFI-5585
Please refer to https://issues.apache.org/jira/browse/NIFI-5585 for a
description of use-cases for decommissioning nodes. This PR is based off of
work that is being done via https://issues.apache.org/jira/browse/NIFI-5516.
This is a work-in-progress PR. Nodes can be decommissioned, the flowfiles
on the decommissioning node get moved to other nodes that are still connected
to the cluster.
A node can be decommissioned by first disconnecting it using the cluster
node table's "Disconnect" icon, and then clicking on the "Decommission" icon.
Some things that still need to be done in this PR:
- Unit/integration tests need to be added
- On the decommissioned node's UI, the status should represent its state.
Currently, a node that is being decommissioned will show as "Disconnected" on
the node's UI.
- Upgrading FontAwesome from 4.6.1 to 4.7 to use an icon for the
"Decommission" action other than fa-sun-o, most likely window-close-o
- There are various TODO markers in the code, where further testing needs
to be done. Also, some follow-on JIRAs will be created based off of some of
the TODOs.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jtstorck/nifi NIFI-5585
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/nifi/pull/3010.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3010
----
commit fcc0fed53df4a65ce1e7275d67865d47b61c3bc1
Author: Mark Payne <markap14@...>
Date: 2018-06-14T15:57:21Z
Refactoring StandardFlowFileQueue to have an AbstractFlowFileQueue
Refactored more into AbstractFlowFileQueue
Added documentation, cleaned up code some
Refactored FlowFileQueue so that there is SwappablePriorityQueue
Several unit tests written
Added REST API Endpoint to allow PUT to update connection to use load
balancing or not. When enabling load balancing, though, I saw the queue size go
from 9 to 18. Then was only able to process 9 FlowFiles.
Bug fixes
Code refactoring
Added integration tests, bug fixes
Refactored clients to use NIO
Bug fixes. Appears to finally be working with NIO Client!!!!!
commit 85606cbc200c49a0590c6979aa438addc42f8266
Author: Mark Payne <markap14@...>
Date: 2018-07-27T16:40:14Z
NIFI-5516: Refactored some code from NioAsyncLoadBalanceClient to
LoadBalanceSession
Bug fixes and allowed load balancing socket connections to be reused
Implemented ability to compress Nothing, Attributes, or Content +
Attributes when performing load-balancing
Added flag to ConnectionDTO to indicate Load Balance Status
Updated Diagnostics DTO for connections
Store state about cluster topology in NodeClusterCoordinator so that the
state is known upon restart
Code cleanup
Fixed checkstyle and unit tests
commit d5d9a8ffedf080cfdfb6d8c0c83d498fd3c25022
Author: Mark Payne <markap14@...>
Date: 2018-09-06T13:09:08Z
NIFI-5516: Updating logic for Cluster Node Firewall so that the node's
identity comes from its certificate, not from whatever it says it is.
commit d5a3286252410e8ed2085ba2521e8f0053290bc9
Author: Mark Payne <markap14@...>
Date: 2018-09-10T21:06:05Z
NIFI-5516: FIxed missing License headers
commit 5379a7cd2fe5620faf51cf8c95c8e6d78cc7a982
Author: Jeff Storck <jtswork@...>
Date: 2018-09-18T21:09:13Z
NIFI-5585 Added capability to decommission a node that is disconnected from
the cluster.
----
---
