0

我正在 flink scala 中编写一个简单的程序，它显示消费（csm）超过某个阈值（100）的人的姓名和客户的 ID。程序的编译成功完成但是我有以下异常并且我没有看到输出。我正在使用 IDE IntelliJ。

任何帮助..谢谢。

class Client(val name: String, val id:String, val csm: Int) {
  var name_ :String = name;
  var id_ : String = id;
  var csm_ : Int = csm;

  override def toString():String =
  {
   return "Name = " + name_.toString()+".." + "Id = " +id_.toString()
  }

}
object BatchJob {

  val thresold = 100;

  def main(args: Array[String]) {
    // set up the batch execution environment
    val env = ExecutionEnvironment.getExecutionEnvironment

    val client_sample : DataSet[Client] = env.fromElements[Client](
      new Client("Ali Ahmed", "Or70110233", 150),
      new Client("Jean David", "Alg90030456", 80),
      new Client("Ann Hathayway", "Msr65120289", 130)
    );

    val client_excess: DataSet[Client] = client_sample.filter(p => p.csm> thresold);

    client_excess.print();


    // execute program
    env.execute("Flink Batch Scala API Skeleton")
  }
}

Exception in thread "main" java.lang.NoClassDefFoundError: scala/collection/Seq
    at flinkpack.BatchJob.main(BatchJob.scala)
Caused by: java.lang.ClassNotFoundException: scala.collection.Seq
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
    ... 1 more

Process finished with exit code 1
4

1 回答 1

0

我找到了我的 pb 的解决方案，实际上我们需要做的只是去项目结构 -> 模块 -> 依赖项将库从“提供”状态转换为“编译”状态。

于 2021-02-02T02:37:07.057 回答