From a085ea323282fb3999fd76da495226484f8194df Mon Sep 17 00:00:00 2001 From: soulmachine Date: Thu, 25 Mar 2021 04:30:24 -0700 Subject: [PATCH] Skip check if redis_datatype is channel --- reader/redis/redis.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) } }