Package | Description |
---|---|
org.apache.flink.client |
Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.waitUntilJobInitializationFinished(SupplierWithException<JobStatus,Exception> jobStatusSupplier,
SupplierWithException<JobResult,Exception> jobResultSupplier,
ClassLoader userCodeClassloader)
This method blocks until the job status is not INITIALIZING anymore.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.