diff --git a/lib/PoolCluster.js b/lib/PoolCluster.js
index 43e0e08b2..373db8bad 100644
--- a/lib/PoolCluster.js
+++ b/lib/PoolCluster.js
@@ -150,7 +150,8 @@ PoolCluster.prototype._getConnection = function(node, cb) {
       self._increaseErrorCount(node);
       
       if (self._canRetry) {
-        console.warn('[Error] PoolCluster : ' + err);        
+        err.pool = node.pool;
+        self.emit('warn', err);
         return cb(null, 'retry');
       } else {
         return cb(err);