Thank you for your response!
I have not tried the flink run app.jar route because the
way the app is set up does not allow me to do it. Basically,
the app is a web application which serves the UI and also
submits a Flink job for running Cypher queries. It is a
proof-of-concept app, but IMO, a very useful one.
Here's how you can reproduce:
2) cd gradoop_demo
3) git checkout dev => dev is the branch where my
changes to make gradoop work with remote environment go.
4) mvn clean package => should bring the gradoop JARs
that this app needs; these JARs should then be placed in
<flink-install>/lib, cp target/gradoop-demo-0.2.0.jar
6) start the local flink cluster (I have tried with latest
(built-from-source) 1.6-SNAPSHOT, or 1.4)
<flink-install>/bin/start-cluster.sh -- note the JM host
7) <gradoop-demo>/start.sh --jmhost <host>
--jmport 6123 (adjust host and port per your cluster) =>
this is now configured to talk to the RemoteEnvironment at
given JM host and port.
9) hit the query button => this would throw the
11) do 9 again and see the results shown nicely in the
Here is the relevant code:
The instructions are correct to my knowledge. Thanks for
your willingness to try. I have tried everything I can. With
different Flink versions, I get different results (I have also
tried on 1.6-SNAPSHOT with class loading config being
parent-first, or child-first).