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() }} 代码报错

这段代码报错的原因是没有正确导入 Flink 的 ExecutionEnvironment 类。

你需要在文件开头添加以下导入语句：

import org.apache.flink.api.scala.ExecutionEnvironment

这样就可以正确使用 ExecutionEnvironment 类了。另外，filePath 变量中的字符串 "path/to/file.txt" 也需要替换成实际的文件路径。