您好！
十分感谢您的回答！之前有进行尝试，但是还是没有解决这个问题。最后觉得应该是jar包不能读取到，所以把那个jar包单独放到了flink的lib下面，运行成功了。还没有找到一劳永逸解决的办法，不过十分感谢您的回复，谢谢~
Best wishes,
Gege
| |
Ge Ge
Software Engineer
|
|
gg13871077...@163.com
|
签名由网易邮箱大师定制
在2020年09月25日 16:01，zilong xiao 写道：
有可能是依赖冲突了，可以尝试用maven shade jar看看
GeGe 于2020年9月25日周五
Document，所以就换成了String类型。现在报错的类也是在同一个jar包下：mongo-driver-java-3.8.2.jar
,换了各种版本，解压maven的jar包查看也有这个jar包。现在就是不知道为什么找不到这个jar包下的任何类。
请求各位大神帮帮忙~~非常非常感谢~~
Best wishes,
Gege
| |
Ge Ge
Software Engineer
|
|
gg13871077...@163.com
|
签名由网易邮箱大师定制
您好！
我刚开始接触flink，现在准备用flink读取mongdb中的数据。mongodb中每秒都会有一个新增数据，重写RichSourceFunction来连接读取mongodb中数据。但是flink不能像kafka一样，持续不断显示数据，是否mongodb不能持续显示数据呢？还是有一些额外设置？
十分感谢！
Best wishes，
Gege
