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 450daec423..42428f60e2 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 @@ -904,7 +904,10 @@ public class EndpointConnectionPool { return listeningPort; } - + @Override + public String toString() { + return "EndpointConnectionPool[Cluster URL=" + clusterUrl + "]"; + } /** diff --git a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java index 2fbcfc4bd1..a1ce07e450 100644 --- a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java +++ b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java @@ -138,7 +138,7 @@ public class SocketClientTransaction implements Transaction { this.dataAvailable = true; break; case FINISH_TRANSACTION: - logger.debug("{} {} Indicates Transaction should finish", peer); + logger.debug("{} {} Indicates Transaction should finish", this, peer); this.dataAvailable = false; break; default: