【踩坑】Flink无法使用Jedis连接redis服务器_flink map里不能序列化redis连接

作者：人工智能uu | 2024-06-29 00:00:20

踩

flink map里不能序列化redis连接

现象:在本地环境Flink流处理的task 用main函数可以运行但是打包成jar包部署到Flink上就运行失败

过程：

项目使用Flink-scala写的 scala没有相关连接redis的包但是Jedis只支持Java版本所以写了个JedisUtil类用scala调用方法来创建jedis session 工具类中都使用静态方法与变量编写

部署上去发现不行

后来将JedisUtil改成非静态的成员变量和方法后再部署就可以运行了

原因: scala似乎不支持java类的静态方法与静态成员变量的调用所以需要将Java的Util类均采用非static的写法创建一个新的Util对象

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/人工智能uu/article/detail/767735