报错原因是：集群 scala 版本和项目的不匹配，需降低项目的 scala 版本，并且，如果引用了其他依赖包，也要进行相应的版本降低，而且各框架之间要兼容。例如：scala是2.11版本，要对应flink-connector-kafka_2.11，如果flink-connector-kafka_2.12，也会报这个错。