title: Flink Scala ClassNotFoundException: org.apache.flink.api.common.typeinfo.TypeInformation
body: <p>I am new to Flink and I was following the SocketWindowWordCount example. </p>
  
  <p>I am using Scala 2.11.8 and Flink 1.3.2 and try to run it on EMR, when I run the following code, it threw errors:</p>
  
  <pre><code>Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.typeinfo.TypeInformation
  </code></pre>
  
  <p>The main class looks like this:</p>
  
  <pre><code>import org.apache.flink.streaming.api.scala._
  import org.apache.flink.streaming.api.windowing.time.Time
  
  object FlinkStreamingPOC {
  
    def main(args: Array[String]) : Unit = {
      val env = StreamExecutionEnvironment.getExecutionEnvironment
      val stream = env.readTextFile("s3a://somebucket/prefix")
      val counts = stream.flatMap{ _.split("\\W+") }
        .map { (_, 1) }
        .keyBy(0)
        .timeWindow(Time.seconds(10))
        .sum(1)
  
      counts.print
  
      env.execute("Window Stream WordCount")
    }
  }
  </code></pre>
  
  <p>build.sbt looks like this:</p>
  
  <pre><code>scalaVersion := "2.11.8"
  
  val flinkVersion = "1.3.2"
  
  libraryDependencies ++= Seq(
    "org.apache.flink" %% "flink-scala" % flinkVersion,
    "org.apache.flink" %% "flink-streaming-scala" % flinkVersion
  )
  </code></pre>
  
  <p>I tried to <code>import org.apache.flink.api.scala._</code> and <code>org.apache.flink.streaming.api.scala._</code> but still got the same error message. Please suggest, thanks!</p>