退订

在map算子中对redis进行sadd写入之后再sget读取

各位： 晚上好！ 对于redis作为数据源或者sink网上有很多参照的案例，那么请问如何在一个map算子里面，先写入set结构中，然后再读取该set的长度呢？ 业务需要，百思不得解，还望各位指点迷津！ 祝好！ | | 追梦的废柴 | | 邮箱：zhuimeng...@163.com | 签名由 网易邮箱大师 定制

使用RedisSink无法将读取的Kafka数据写入Redis中

各位： 晚上好！ 现在我所在的项目组在调研Flink框架，有一个指标需要读取Kafka中的数据然后使用Redis存储最终的结果。 我们在pom文件中引入了flink-redis的connector，然后按照官方的RedisSink案例，在本地开发的时候可以正常写入到某台服务器上的Redis中， 但是当我把程序打成Jar包之后，部署到服务器（华为云MRS）上使用flink run提交到yarn之后总是在报错，无法写入到Redis中，各位知道是为什么吗？ 问题已经卡了我两天了，一点进展都没有，有劳各位帮忙解答一下，Thank you！ 报错如下：