Sorry, correcting myself: The ClosureCleaner uses Kryo's bundled ASM 4 without any reason - simply adjusting the imports to use the common ASM (which is 5.0) should do it ;-)
On Mon, Dec 7, 2015 at 8:18 PM, Stephan Ewen <se...@apache.org> wrote: > 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 <cory.mo...@getbraintree.com> > 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 <m...@apache.org> >> wrote: >> >>> For completeness, could you provide a stack trace of the error message? >>> >>> On Mon, Dec 7, 2015 at 6:56 PM, Maximilian Michels <m...@apache.org> >>> 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 < >>> cory.mo...@getbraintree.com> 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 >>> >> >> >
