diff --git a/reader/redis/redis.go b/reader/redis/redis.go index 356253a55..ffcc947c9 100644 --- a/reader/redis/redis.go +++ b/reader/redis/redis.go @@ -101,7 +101,7 @@ func NewReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error) { for _, val := range opt.key { keyType, _ := client.Type(val).Result() - if dataType != keyType { + if keyType != "none" && dataType != keyType { return nil, fmt.Errorf("key[%v]'s type expect as %v,actual get %v", val, dataType, keyType) } }