游客kflzewkm76uni_个人页

应该是集群环境的问题，你的代码里虽然把jar加到了classpath，但是只在driver上被执行了，job提交到别的node的taskmanager上时，会把对象反序列化出来，这个时候就找不到类了。我临时解决方案就是修改pyflink-stream.sh文件, 需要保证每个node上都有这些对应位置的jar存在。

/opt/apps/flink/flink run --classpath file:///opt/apps/flink/kafka/flink-connector-kafka-0.10_2.11-1.8.0.jar --classpath file:///opt/apps/flink/kafka/flink-connector-kafka-0.9_2.11-1.8.0.jar --classpath file:///opt/apps/flink/kafka/flink-connector-kafka-base_2.11-1.8.0.jar --classpath file:///opt/apps/flink/kafka/snappy-java-1.1.2.6.jar --classpath file:///opt/apps/flink/kafka/force-shading-1.8.0.jar --classpath file:///opt/apps/flink/kafka/kafka-clients-0.10.2.1.jar --classpath file:///opt/apps/flink/kafka/lz4-1.3.0.jar --class org.apache.flink.streaming.python.api.PythonStreamBinder -v /opt/apps/flink/opt/flink-streaming-python*.jar "$@"

有些变量被我写死了，可以恢复回去。