Hello all,
i am trying to run some relational queries on flink over yarn,
i found two repo (https://github.com/stratosphere/stratosphere-tpch,
https://github.com/project-flink/flink-perf ) with the java and scala
implementation for some of the bench queries.
Running some of them with scale factor 64 the reading of the dataset
seems to be bottleneck.
Cause im new in the flink community, is there any way to implement those
queries more efficient ?
Also are there any results of this benchmark for the flink-yarn ??
Thanks in advance,
Alex
