import org.apache.flink.api.scala.ExecutionEnvironment import org.apache.flink.api.scala._ import java.nio.file.Pathsobject SumCount { def main(args: Array[String]): Unit = { // 第1步：建立执行环境 val env = ExecutionEnvironment.getExecutionEnvironment // 第2步：创建数据源 val filePath = Paths.get("path/to/file.txt") val data = env.readTextFile(filePath.toString) .map { line => val Array(className, scoreStr) = line.split(",") (className, scoreStr.toInt) } // 第3步：对数据集指定转换操作 val counts = data .groupBy(0) .sum(1) // 第4步：输出结果 counts.print() }} 代码报错

根据你提供的代码，我看到可能有两个问题：

1. 缺少 Flink 库的依赖。你需要在项目的 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-scala_2.11</artifactId>
    <version>1.13.0</version>
</dependency>

2. 你需要将 `filePath` 变量中的字符串 "path/to/file.txt" 替换成实际的文件路径。

另外，如果你的文本文件中的数据是用逗号隔开的，那么程序可以按照当前的方式来处理。如果你的数据格式不同，需要根据实际情况进行调整。

请尝试按照以上方式修改代码并重新运行，如果还有问题，可以给出具体的错误信息或者异常堆栈信息，这样我才能更好地帮助你解决问题。