diff --git a/common_utils/component_state_helper.go b/common_utils/component_state_helper.go index 3045cca8..205b7f03 100644 --- a/common_utils/component_state_helper.go +++ b/common_utils/component_state_helper.go @@ -16,18 +16,20 @@ func getRedisDBClient() (*redis.Client, error) { addr, err := sdcfg.GetDbTcpAddr(dbName, ns) if err != nil { log.Errorf("Addr err: %v", err) - return + return nil, err } db, err := sdcfg.GetDbId("STATE_DB", ns) if err != nil { log.Errorf("DB err: %v", err) - return + return nil, err } rclient := redis.NewClient(&redis.Options{ Network: "tcp", Addr: addr, + Addr: addr, Password: "", // no password set DB: db, + DB: db, DialTimeout: 0, }) if rclient == nil {