If you set DeploymentOptions.ATTACHED to false then execute() does not
block until the job finishes, and returns a DetachedJobExecutionResult
from which you can retrieve the Job ID.
If you need to know when the job finishes you will have to continuously
query the REST API.
This is the only way
Hi,
Thanks for your reply and explanation!
Do you know of any way to have a job retrieve its own jobID while it's still
running?
Best,
Annemarie
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(config) does
not actually create any resources yet, this only happens when you run a
job. Upon execute() the Flink cluster is started, the job is run, and
once the job finishes (and execute() returns) the cluster shuts down.
So, you can
Hi,
Thanks for your response!
I can't seem to get past a "java.net.ConnectException: Connection refused"
though. Below is the relevant code and exception, any idea what I'm doing
wrong?
Configuration config = new Configuration();
config.setString(JobManagerOptions.ADDRESS, "localhost");
confi
Hi Annemarie,
You need to use http client to connect to the job managaer.
//Creating a HttpClient object
CloseableHttpClient httpclient = HttpClients.createDefault();
//Creating a HttpGet object
HttpGet httpget = new HttpGet("https://${jobmanager:port}/jobs ");
//Exec
