Hi, I am just exploring Flink, and have run into a curious issue. I have cloned from github, checked out the release-1.0.0-rc1 branch, and built from command line - no errors. I am using IntelliJ. I first tried running some of the batch examples, and those run fine. Then I tried stream examples (flink-examples-streaming, e.g. java/WordCount or scala/WindowJoin), and I get this error:

/Users/taraathan/Repositories/IntelliJIDEA/flink/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/StreamingScalaAPICompletenessTest.scalaError:(22, 35) object completeness is not a member of package org.apache.flink.api.scala
import org.apache.flink.api.scala.completeness.ScalaAPICompletenessTestBase

It is the same on every streaming example. What am I doing wrong?

Thanks, Tara

Reply via email to