Re: Using Flink with Scala 2.11 and Java 8

2015-12-10 Thread Cory Monty
Thanks! On Thu, Dec 10, 2015 at 12:32 PM, Maximilian Michels wrote: > Hi Cory, > > The issue has been fixed in the master and the latest Maven snapshot. > https://issues.apache.org/jira/browse/FLINK-3143 > > Cheers, > Max > > On Tue, Dec 8, 2015 at 12:35 PM, Maximilian Michels > wrote: > > Than

Re: Using Flink with Scala 2.11 and Java 8

2015-12-10 Thread Maximilian Michels
Hi Cory, The issue has been fixed in the master and the latest Maven snapshot. https://issues.apache.org/jira/browse/FLINK-3143 Cheers, Max On Tue, Dec 8, 2015 at 12:35 PM, Maximilian Michels wrote: > Thanks for the stack trace, Cory. Looks like you were on the right > path with the Spark issue

Re: Using Flink with Scala 2.11 and Java 8

2015-12-08 Thread Maximilian Michels
Thanks for the stack trace, Cory. Looks like you were on the right path with the Spark issue. We will file an issue and correct it soon. Thanks, Max On Mon, Dec 7, 2015 at 8:20 PM, Stephan Ewen wrote: > Sorry, correcting myself: > > The ClosureCleaner uses Kryo's bundled ASM 4 without any reason

Re: Using Flink with Scala 2.11 and Java 8

2015-12-07 Thread Stephan Ewen
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 wrote: > Flink's own asm is 5.0, but the Kryo version used in Flink bundles

Re: Using Flink with Scala 2.11 and Java 8

2015-12-07 Thread Stephan Ewen
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 wrote: > Thanks, Max. > > Here is the stack trace I receive: > > ja

Re: Using Flink with Scala 2.11 and Java 8

2015-12-07 Thread Cory Monty
Thanks, Max. Here is the stack trace I receive: java.lang.IllegalArgumentException: at com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassReader.(Unknown Source) at com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassReader.(Unknown Source) at com.esotericsoftware.reflectasm

Re: Using Flink with Scala 2.11 and Java 8

2015-12-07 Thread Maximilian Michels
For completeness, could you provide a stack trace of the error message? On Mon, Dec 7, 2015 at 6:56 PM, Maximilian Michels 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

Re: Using Flink with Scala 2.11 and Java 8

2015-12-07 Thread Maximilian Michels
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:

Using Flink with Scala 2.11 and Java 8

2015-12-07 Thread Cory Monty
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,