diff --git a/pkg/redis/server/pool.go b/pkg/redis/server/pool.go
index 5c3af5f4..9ceccee4 100644
--- a/pkg/redis/server/pool.go
+++ b/pkg/redis/server/pool.go
@@ -71,8 +71,8 @@ func (pool *ServerPool) indexByHostPort() map[string]*Server {
 	return index
 }
 
-func (pool *ServerPool) GetServerAlias(connectionString string) string {
-	if srv, err := pool.GetServer(connectionString, nil); err == nil {
+func (pool *ServerPool) GetServerAlias(hostport string) string {
+	if srv, err := pool.GetServer("redis://"+hostport, nil); err == nil {
 		return srv.alias
 	} else {
 		return ""