使用Scala IDE和SBT的Flink

Question

val env = ExecutionEnvironment.getExecutionEnvironment
val text = env.fromElements("first line", "second line")

import AssemblyKeys._

name := "Flink Test"
version := "0.1.0"
organization := "com.NNN"
scalaVersion := "2.10.4"

javacOptions ++= Seq("-source", "1.7", "-target", "1.7")

libraryDependencies ++= Seq(
  "org.apache.flink" % "flink-scala" % "0.10.1" % "provided",
  "org.apache.flink" % "flink-clients" % "0.10.1" % "provided"
)

resolvers ++= Seq(
  "Akka"                    at "http://akka.io/repository/",
  "Sonatype"                at "https://oss.sonatype.org/"
)

assemblySettings

jarName in assembly := "flink-test.jar"

fork in run := true

assemblyOption in assembly :=  (assemblyOption in assembly).value.copy(includeScala = false)

Answer 1

更新

从引用的链接

请注意，这意味着在兼容性2.10模式下当前不可能扩展白盒宏。实际上，宏已经知道2.10和2.11之间最近的重要发展，这使得在两者之间进行类型检查兼容性非常困难。如果您有一个重要的项目使用2.10whitebox宏，那么您可能想看看Scala IDE的2.10版本。

项目>属性>Scala编译器

如果需要，请选中使用项目设置

在Scala安装中，选择2.10并单击OK。