This might be related to the problem mentioned in https://issues.apache.org/jira/browse/FLINK-3241 and http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/flink-1-0-SNAPSHOT-scala-2-11-compilation-error-td4303.html .
Cheers, Till On Sun, Jan 17, 2016 at 6:26 PM, Prez Cannady <revp...@correlatesystems.com> wrote: > I concur. Already had "import org.apache.flink.streaming.api.scala._”, > and just tried adding "import org.apache.flink.api.scala._”. Same issue. > > > > Prez Cannady > p: 617 500 3378 > e: revp...@opencorrelate.org <mailto:revp...@opencorrelate.org> > GH: https://github.com/opencorrelate <https://github.com/opencorrelate> > LI: https://www.linkedin.com/in/revprez < > https://www.linkedin.com/in/revprez> > > > > > > > > > > > On Jan 17, 2016, at 8:59 AM, Aljoscha Krettek <aljos...@apache.org> > wrote: > > > > Hi, > > I think it’s more complicated than a missing import statement (the code > has the correct import statement). I’ll look into it. > > > > Cheers, > > Aljoscha > >> On 17 Jan 2016, at 13:32, Stephan Ewen <se...@apache.org> wrote: > >> > >> Hi! > >> > >> I think this no Scala version issue, you probably miss an import > statement: > >> > >> "import org.apache.flink.streaming.api.scala._" or "import > >> org.apache.flink.api.scala._" > >> > >> See also here: > >> > http://flink.apache.org/faq.html#in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters > >> > >> Greetings, > >> Stephan > >> > >> On Sat, Jan 16, 2016 at 9:09 PM, Prez Cannady < > revp...@opencorrelate.org> > >> wrote: > >> > >>> Attempting to get settled with Flink under Scala 2.11, but running into > >>> some odd issues with macro expansion in a project that depends on > >>> flink-scala_2.11 and flink-runtime_211. > >>> > >>> I’ve instrumented the SocketStreamWordCount quick start < > >>> https://github.com/OCExercise/wordcount-processing> to test this > issue. > >>> It depends on Flink 1.0-SNAPSHOT, so you can test against a local > build of > >>> Flink for 2.11. > >>> > >>> Steps taken > >>> > >>> Cloned source and checked out release-0.1 > >>> Ran tools/change-scala-version.sh 2.11 > >>> Ran mvn clean install -Dscala.version=2.11.4 > -Dscala.binary.version=2.11 > >>> -Dakka.version=2.4.1 -DskipTests=true at Flink root; build succeeds > >>> Ran my spring-booted downstream project’s build and boot run. > >>> Expected result > >>> > >>> Success > >>> > >>> Actual result > >>> > >>> During compilation, I get the following error: > >>> > >>> [ERROR] > >>> > /Users/revprez/dev/exercise/systems/jvm/flink/wordcount-processing/src/main/scala/org/opencorrelate/jvm/scala/SocketTextStreamWordCount.scala:73: > >>> error: could not find implicit value for evidence parameter of type > >>> org.apache.flink.api.common.typeinfo.TypeInformation[String] > >>> [ERROR] val counts = text.flatMap { _.toLowerCase.split("\\W+") > >>> filter { _.nonEmpty } } > >>> [ERROR] ^ > >>> [ERROR] > >>> > /Users/revprez/dev/exercise/systems/jvm/flink/wordcount-processing/src/main/scala/org/opencorrelate/jvm/scala/WordCount.scala:40: > >>> error: can't expand macros compiled by previous versions of Scala > >>> [ERROR] val text = env.fromElements("To be, or not to be,--that is > the > >>> question:--", > >>> > >>> > >>> Discussion > >>> > >>> I’m not sure how the Maven build actually succeeded, as there doesn’t > seem > >>> to be any quasiquotes_2.11 under org.scalamacros < > >>> http://central.maven.org/maven2/org/scalamacros/> of any version in > the > >>> public repos, nor in the four vendor repos configured in flink-parent’s > >>> pom.xml. Unless I’m missing something, > >>> > >>> <dependencies> > >>> <dependency> > >>> <groupId>org.scalamacros</groupId> > >>> > >>> <artifactId>quasiquotes_${scala.binary.version}</artifactId> > >>> <version>${scala.macros.version}</version> > >>> </dependency> > >>> </dependencies> > >>> > >>> > >>> I recall an earlier discussion about issues with 2.10 stuff polluting > the > >>> 2.11 build. Not sure if this is related–I’m able to get through > everything > >>> I’ve identified up to this point by simply overriding properties in > >>> flunk-parent with command line arguments. > >>> > >>> Also not sure what next steps to take. Don’t know enough about Scala > >>> Macros to know if substituting, say, > org.scalameta:quasiquotes_2.11:0.0.4 > >>> is a viable option (actually tried it, seems to be more trouble than > it’s > >>> worth). > >>> > >>> If anyone has any ideas, I’m more than willing to try thing—Flink’s on > our > >>> critical path and if we can get it operational under 2.11 then we’er > golden. > >>> > >>> > >>> > >>> Prez Cannady > >>> p: 617 500 3378 > >>> e: revp...@opencorrelate.org <mailto:revp...@opencorrelate.org> > >>> GH: https://github.com/opencorrelate <https://github.com/opencorrelate > > > >>> LI: https://www.linkedin.com/in/revprez < > >>> https://www.linkedin.com/in/revprez> > >>> > >>> > >>> > >>> > >>> > >>> > >>> > >>> > >>> > >>> > > > >
