Apache Flink DataStream类文件缺失及Cassandra写入代码问题求助

嘿，这个问题我之前帮不少开发者排查过，核心原因基本都和依赖配置或者API混用有关，结合你用的Flink 1.3.2版本，给你几个针对性的解决办法：

1. 补充Scala Streaming依赖（最常见原因） #

org.apache.flink.streaming.api.scala.DataStream是Flink Scala专属API的类，你的Java代码如果间接用到了（比如Cassandra连接器依赖了Scala API），就必须引入对应版本的Scala Streaming依赖。

Maven依赖示例 #

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-scala_2.11</artifactId> <!-- Flink 1.3.2对应Scala 2.11版本 -->
    <version>1.3.2</version>
    <!-- 本地运行可去掉provided；提交集群时保留，集群会自带核心依赖 -->
    <scope>provided</scope>
</dependency>

Gradle依赖示例 #

// 本地运行用compile，集群提交用compileOnly
compile group: 'org.apache.flink', name: 'flink-streaming-scala_2.11', version: '1.3.2'

2. 切换到Java原生DataStream API #

既然你写的是Java代码，建议直接用Flink Java API的DataStream，完全没必要依赖Scala版本的类，修改导入语句即可：

// 替换成Java版DataStream
import org.apache.flink.streaming.api.datastream.DataStream;

这样既能避免Scala依赖问题，也更贴合Java项目的编码习惯。

3. 校验Cassandra连接器版本匹配 #

Flink Cassandra连接器的版本必须和Flink核心版本严格一致，否则会出现依赖冲突或缺失。你用Flink 1.3.2的话，连接器也要用对应版本：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-cassandra_2.11</artifactId>
    <version>1.3.2</version>
</dependency>

4. 检查运行时ClassPath #

• 本地IDE运行：确保你的运行配置里包含了所有依赖，没有遗漏Scala相关jar包；
• 集群提交：如果依赖标记了provided，要确认集群节点的ClassPath里有Flink Scala Streaming的jar包，或者直接把依赖打包进项目jar（去掉provided范围）。

内容的提问来源于stack exchange，提问作者Soheil Pourbafrani