Flink's own asm is 5.0, but the Kryo version used in Flink bundles reflectasm with a dedicated asm version 4 (no lambdas supported).
Might be as simple as bumping the kryo version... On Mon, Dec 7, 2015 at 7:59 PM, Cory Monty <[email protected]> wrote: > Thanks, Max. > > Here is the stack trace I receive: > > java.lang.IllegalArgumentException: > > at > com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassReader.<init>(Unknown > Source) > at > com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassReader.<init>(Unknown > Source) > at > com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassReader.<init>(Unknown > Source) > at > org.apache.flink.api.scala.ClosureCleaner$.org$apache$flink$api$scala$ClosureCleaner$$getClassReader(ClosureCleaner.scala:47) > at > org.apache.flink.api.scala.ClosureCleaner$.getInnerClasses(ClosureCleaner.scala:90) > > at > org.apache.flink.api.scala.ClosureCleaner$.clean(ClosureCleaner.scala:113) > > at > org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.scalaClean(StreamExecutionEnvironment.scala:555) > > at > org.apache.flink.streaming.api.scala.DataStream.clean(DataStream.scala:764) > > at > org.apache.flink.streaming.api.scala.DataStream.flatMap(DataStream.scala:473) > > > On Mon, Dec 7, 2015 at 11:58 AM, Maximilian Michels <[email protected]> > wrote: > >> For completeness, could you provide a stack trace of the error message? >> >> On Mon, Dec 7, 2015 at 6:56 PM, Maximilian Michels <[email protected]> >> wrote: >> > Hi Cory, >> > >> > Thanks for reporting the issue. Scala should run independently of the >> > Java version. We are already using ASM version 5.0.4. However, some >> > code uses the ASM4 op codes which don't seem to be work with Java 8. >> > This needs to be fixed. I'm filing a JIRA. >> > >> > Cheers, >> > Max >> > >> > On Mon, Dec 7, 2015 at 4:15 PM, Cory Monty <[email protected]> >> wrote: >> >> Is it possible to use Scala 2.11 and Java 8? >> >> >> >> I'm able to get our project to compile correctly, however there are >> runtime >> >> errors with the Reflectasm library (I'm guessing due to Kyro). I >> looked into >> >> the error and it seems Spark had the same issue >> >> (https://issues.apache.org/jira/browse/SPARK-6152, >> >> https://github.com/EsotericSoftware/reflectasm/issues/35) because of >> an >> >> outdated version of Kyro. >> >> >> >> I'm also unsure if maybe we have to build Flink with Scala 2.11 >> >> ( >> https://ci.apache.org/projects/flink/flink-docs-release-0.10/setup/building.html >> ) >> >> in order to run Flink correctly with Java 8. >> >> >> >> Cheers, >> >> >> >> Cory >> > >
