Hi Till,
the problem is that this is the only output :( Or is it possible to get
a more verbose log output?
Maybe it is important to note, that both Flink and our project is built
with Scala 2.11.
Best Regards,
Philipp
On 16.07.2015 11:12, Till Rohrmann wrote:
Hi Philipp,
could you post the complete log output. This might help to get to the
bottom of the problem.
Cheers,
Till
On Thu, Jul 16, 2015 at 11:01 AM, Philipp Goetze
<[email protected] <mailto:[email protected]>>
wrote:
Hi community,
in our project we try to submit built Flink programs to the
jobmanager from within Scala code. The test program is executed
correctly when submitted via the wrapper script "bin/flink run
..." and also with the webclient. But when executed from within
the Scala code nothing seems to happen, but the following warning
is found in the log:
10:47:18,153 WARN akka.remote.ReliableDeliverySupervisor
- Association with remote system [akka.tcp://[email protected]:34074
<mailto:akka.tcp://[email protected]:34074>] has failed, address is now gated for
[5000] ms. Reason is: [org.apache.flink.runtime.jobgraph.AbstractJobVertex]
Our submit method looks like that:
def submitJar(master: String, path: String, className: String, args:
String*) = {
val file = new File(path)
val parallelism = 1
val wait = true
try {
val program = new PackagedProgram(file, className, args:_*)
val jobManagerAddress = getInetFromHostport(master)
val client = new Client(jobManagerAddress, new Configuration(),
program.getUserCodeClassLoader(), 1)
println("Executing " + path);
client.run(program, parallelism, wait);
} catch {
case e: ProgramInvocationException => e.printStackTrace()
}
}
I took this as a reference:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-submit-flink-jars-from-plain-Java-programs-td656.html
I hope you can help.
Best Regards,
Philipp Götze
