Package | Description |
---|---|
org.apache.flink.runtime.execution.librarycache | |
org.apache.flink.runtime.jobmaster |
Modifier and Type | Method and Description |
---|---|
LibraryCacheManager.ClassLoaderLease |
LibraryCacheManager.registerClassLoaderLease(JobID jobId)
Registers a new class loader lease for the given jobId.
|
LibraryCacheManager.ClassLoaderLease |
BlobLibraryCacheManager.registerClassLoaderLease(JobID jobId) |
Constructor and Description |
---|
JobManagerRunnerImpl(JobGraph jobGraph,
JobMasterServiceFactory jobMasterFactory,
HighAvailabilityServices haServices,
LibraryCacheManager.ClassLoaderLease classLoaderLease,
Executor executor,
FatalErrorHandler fatalErrorHandler,
long initializationTimestamp)
Exceptions that occur while creating the JobManager or JobManagerRunnerImpl are directly
thrown and not reported to the given
FatalErrorHandler . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.