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

回复