Repository: incubator-nifi Updated Branches: refs/heads/NIFI-250 f556490fb -> 50f0c123b
NIFI-409: Fixed NPE Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/053d29dc Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/053d29dc Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/053d29dc Branch: refs/heads/NIFI-250 Commit: 053d29dc1967133e453c8e07f585def88b752cc7 Parents: 3533a4a Author: Mark Payne <[email protected]> Authored: Tue Mar 10 12:01:42 2015 -0400 Committer: Mark Payne <[email protected]> Committed: Tue Mar 10 12:01:42 2015 -0400 ---------------------------------------------------------------------- .../apache/nifi/remote/client/socket/EndpointConnectionPool.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/053d29dc/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java index 885f357..e80f328 100644 --- a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java +++ b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java @@ -314,7 +314,6 @@ public class EndpointConnectionPool { if ( protocol.isDestinationFull() ) { logger.warn("{} {} indicates that port's destination is full; penalizing peer", this, peer); penalize(peer, penalizationMillis); - connectionQueue.offer(connection); continue; } else if ( protocol.isPortInvalid() ) { penalize(peer, penalizationMillis);
