看起来flink-streaming-java应该不在class path下面,如果是官网下的flink,直接在FLINK_HOME下执行./bin/flink run提交job应该就不会出错。另外这个错误我理解本身和remote shuffle应该关系不大,不用remote shuffle,应该也会抛。建议是从官网下载一个Flink版本再试一下。
- flink remote shuffle example运行出错 casel.chen
- Re: flink remote shuffle example运行出错 weijie guo
- Re: flink remote shuffle example运行出错 Yingjie Cao
- Re:Re: flink remote shuffle example运行出错 casel.chen