public class HistoryServer extends Object
The HistoryServer regularly checks a set of directories for job archives created by the FsJobArchivist
and
caches these in a local directory. See HistoryServerArchiveFetcher
.
All configuration options are defined inHistoryServerOptions
.
The WebInterface only displays the "Completed Jobs" page.
The REST API is limited to
HistoryServerStaticFileServerHandler
.Constructor and Description |
---|
HistoryServer(Configuration config) |
HistoryServer(Configuration config,
java.util.function.Consumer<HistoryServerArchiveFetcher.ArchiveEvent> jobArchiveEventListener)
Creates HistoryServer instance.
|
public HistoryServer(Configuration config) throws IOException, FlinkException
IOException
FlinkException
public HistoryServer(Configuration config, java.util.function.Consumer<HistoryServerArchiveFetcher.ArchiveEvent> jobArchiveEventListener) throws IOException, FlinkException
config
- configurationjobArchiveEventListener
- Listener for job archive operations. First param is operation, second
param is id of the job.IOException
- When creation of SSL factory failedFlinkException
- When configuration error occurredCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.