I tried to run a simple batch job (it tooks about 5 minutes with flink 1.3.1 on single machine), but it seems to run forever with flink 1.5-SNAPSHOT (I stopped it after about 2-3 hours multiple times). If you want to try to replicate this, here are the java classes: https://github.com/xseris/Flink-test-union/tree/master/src/main/java/okkam/it/flink/flink150SNAPSHOT (you first need to generate the test input csv [8 GB] through the RandomCsvGenerator.javaclass).

With flink 1.3.1 all works. Is it only my behavior or is there any problem in the architecture introduced in 1.5?

Thanks,
Simone.

Reply via email to