你遇到的核心问题是Flink集群运行时无法找到Twitter连接器的依赖类——虽然build.sbt里已经配置了依赖，但默认的sbt package打包方式并没有把这些第三方依赖打包进最终的jar包。这也是为什么IntelliJ能正常运行（IDE会自动把所有依赖加载到类路径），但提交到集群就报错的原因。

下面是几种可行的解决方案：

方案1：打包包含所有依赖的Fat Jar（推荐） #

使用sbt-assembly插件生成一个包含所有依赖的"胖jar"，让作业提交时所有需要的类都在同一个jar里，集群可以直接找到。

1. 添加sbt-assembly插件：在项目的project/plugins.sbt文件中添加：

   addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "1.2.0") // 版本可根据你的sbt版本调整
   

2. 配置assembly插件处理依赖冲突：在build.sbt中添加配置，避免log4j、commons-logging这类常见依赖的冲突：

   assemblyMergeStrategy in assembly := {
     case PathList("META-INF", xs @ _*) => MergeStrategy.discard
     case x => MergeStrategy.first
   }
   

3. 生成Fat Jar：在命令行执行：

   sbt assembly
   

   生成的胖jar会在target/scala-2.11/目录下，命名格式一般是[项目名]-assembly-[版本].jar。

4. 提交作业：用这个胖jar提交即可：

   flink run -c org.myClass C:\path\to\fat-jar-file.jar
   

方案2：将Twitter连接器依赖放到Flink集群的lib目录 #

如果不想每次打包都生成胖jar，可以把Twitter连接器的jar包直接放到Flink集群的全局依赖目录，让集群自动加载：

1. 找到flink-connector-twitter的jar包：你可以在本地sbt仓库（通常在~/.ivy2/cache/org.apache.flink/flink-connector-twitter_2.11/jars/）找到对应版本的jar，也可以从Maven仓库直接下载。

2. 复制到集群节点：把这个jar包复制到Flink集群中每个JobManager和TaskManager的lib目录（比如C:\flink-1.x.x\lib，根据你的安装路径调整）。

3. 重启Flink集群：重启所有Flink节点，确保新依赖被加载。

之后再用原来的jar提交作业，集群就能找到TwitterSource相关类了。

方案3：提交作业时动态添加依赖（临时场景） #

如果只是临时测试，可以在提交时用-C参数手动指定依赖jar：

flink run -C file:///C:/path/to/flink-connector-twitter_2.11-x.x.x.jar -c org.myClass C:\path\to\jarFile.jar

这种方式每次提交都要指定依赖，适合临时调试，不推荐长期使用。

补充说明 #

你build.sbt里给flink-connector-twitter不加provided是正确的——因为Flink集群默认不包含这个连接器依赖；而flink-scala和flink-streaming-scala加provided是合理的，因为Flink集群本身已经自带这些核心依赖，不需要重复打包。

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