You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by mc...@apache.org on 2015/03/13 04:02:07 UTC
[17/26] incubator-nifi git commit: NIFI-409: Fixed NPE
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-353
Commit: 053d29dc1967133e453c8e07f585def88b752cc7
Parents: 3533a4a
Author: Mark Payne <ma...@hotmail.com>
Authored: Tue Mar 10 12:01:42 2015 -0400
Committer: Mark Payne <ma...@hotmail.com>
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);