Re: Failure to donwload flink-contrib dependency

2016-11-20 Thread Andrey Melentyev
Hi Juan, flink-contrib itself is just a parent project for a number of others like flink-connector-wikiedits, flink-statebackend-rocksdb, etc. Therefore flink-contrib has it's packaging set to "pom" and no jar is published. Depending on which part of flink-contrib you want, you should add a more s

Re: Compile for Java 1.8

2016-11-14 Thread Andrey Melentyev
igrate to Java > 1.8 > > > > > > On "Build From source > > ": > > > > "Flink requires *at least Java 7* to build. We recommend using Java 8." > > > > > > 2016-11-13 17:48 GMT+01:00 Andrey Melentyev : > > > > >

Re: Compile for Java 1.8

2016-11-13 Thread Andrey Melentyev
Hi Alberto, it seems that this class is not compatible with Java 8 new type inference rules, more specifically the 1.8 compiler picks a different overloaded method than 1.7. In TupleSerializer.java:112 the call to TypeSerializer.copy method in Java 7 resolves to public abstract T copy(T from, T

Re: Too few memory segments provided. Hash Table needs at least 33 memory segments.

2016-11-10 Thread Andrey Melentyev
Hi Miguel, I tried to reproduce the problem in a similar setup using Flink in Docker with 2 workers: CONTAINER IDIMAGE COMMAND CREATED STATUS PORTS NAMES 3fbaf5876e31melentye/flink:latest "docker-entrypoint.sh"