flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nragon <nuno.goncal...@wedotechnologies.com>
Subject Detached execution API
Date Thu, 20 Jul 2017 15:51:39 GMT
It would be nice to let users deploy detached jobs through api.
For instance>


  public JobExecutionResult execute() throws Exception {
    return execute(DEFAULT_JOB_NAME, false);
Which keep backward compatibility

  public abstract JobExecutionResult execute(String jobName, boolean
detached) throws Exception;


  public JobExecutionResult execute(String jobName, boolean detached) throws
ProgramInvocationException {
    StreamGraph streamGraph = getStreamGraph();
    return executeRemotely(streamGraph, jarFiles, detached);


protected JobExecutionResult executeRemotely(StreamGraph streamGraph,
List<URL> jarFiles, boolean detached) throws ProgramInvocationException {
ClusterClient client;
    try {
      client = new StandaloneClusterClient(configuration);

Just an idea. I'm using the previous approach and it works fine.


View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Detached-execution-API-tp14366.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

View raw message