Re: Flink cluster and Java 8

Anyone looking into this? Java 7 reached its end of life at april 2015 with its last public update (numer 80) and the ability to run Java 8 jobs would be more and more important in the future. IMHO, the default target of the maven compiler plugin should be set to 1.8 in the 1.0 release. In most of

Re: Flink cluster and Java 8

I've tested several configurations (also changing my compilation to 1.7 but then sesame 4 was causing the error [1]): 1. Flink compiled with java 1.7 (default), runned within Eclipse with Java 8: OK 2. Flink compiled with java 1.7 (default), runned the cluster with java 8: not able to

Re: Flink cluster and Java 8

Flink compiles correctly using java 8 as long as you leave java 1.7 source and target in the maven java compiler. If you change them to 1.8 flink-core doesn't compile anymore. On Thu, Feb 4, 2016 at 4:23 PM, Maximilian Michels wrote: > Hi Flavio, > > To address your points: > >

Re: Flink cluster and Java 8

yes I did On Thu, Feb 4, 2016 at 5:44 PM, Maximilian Michels wrote: > I see. Did you perform a full "mvn clean package -DskipTests" after > you changed the source level to 1.8? > > On Thu, Feb 4, 2016 at 4:33 PM, Flavio Pompermaier > wrote: > > Flink

Re: Flink cluster and Java 8

Hi Flavio, To address your points: 1) It runs. That's fine. 2) It doesn't work to run a Java 8 compiled Flink job with Java 7 Flink cluster if you use Java 8 non-backwards-compatible features in your job. 3) I compile Flink daily with Java 8. Also, we have Travis CI tests which uses OpenJDK and

Re: Flink cluster and Java 8

I see. Did you perform a full "mvn clean package -DskipTests" after you changed the source level to 1.8? On Thu, Feb 4, 2016 at 4:33 PM, Flavio Pompermaier wrote: > Flink compiles correctly using java 8 as long as you leave java 1.7 source > and target in the maven java

Flink cluster and Java 8

Hi to all, I was trying to make my Java 8 application to run on a Flink 0.10.1 cluster. I've compiled both Flink sources and my app with the same Java version (1.8.72) and I've set the env.java.home to point to my java 8 JVM in every flink-conf.yml of the cluster. I always get the following

Re: Flink cluster and Java 8

I've fixed it changing the copy method in the *TupleSerializer* as follow: @Override public T copy(T from, T reuse) { for (int i = 0; i < arity; i++) { Object copy = fieldSerializers[i].copy(from.getField(i)); reuse.setField(copy, i); } return reuse; } And commenting line 50 in

Re: Flink cluster and Java 8

I've checked the compiled classes with javap -verbose and indeed they had a major.verion=51 (java 7). So I've changed the source and target to 1.8 in the main pom.xm and now the generated .class have major.verion=52. Unfortunately now I get this error: [ERROR]