alluxio.master.journal.ufs

Class UfsJournalCheckpointThread

java.lang.Object

java.lang.Thread

alluxio.thread.AutopsyThread

alluxio.master.journal.ufs.UfsJournalCheckpointThread

All Implemented Interfaces:

Runnable

@NotThreadSafe
public final class UfsJournalCheckpointThread
extends AutopsyThread

This thread continually replays the journal and applies it to the master, until the master initiates the shutdown of the thread. It periodically creates checkpoints. When the thread is stopped while it is writing checkpoint, the checkpoint being written will be cancelled. Once awaitTermination is called, the thread will ignore InterruptedException and shut down like normal (replaying all completed journal logs and waiting for a quiet period to elapse).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UfsJournalCheckpointThread.CatchupState The state of the journal catchup.

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
UfsJournalCheckpointThread(Master master, UfsJournal journal, long startSequence, java.util.function.Supplier<Set<JournalSink>> journalSinks) Creates a new instance of UfsJournalCheckpointThread.
UfsJournalCheckpointThread(Master master, UfsJournal journal, java.util.function.Supplier<Set<JournalSink>> journalSinks) Creates a new instance of UfsJournalCheckpointThread.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination(boolean waitQuietPeriod) Initiates the shutdown of this checkpointer thread, and also waits for it to finish.
UfsJournalCheckpointThread.CatchupState	getCatchupState()
long	getNextSequenceNumber() This should only be called after awaitTermination(boolean).
void	onError(Throwable t) Handles the uncaught error on thread crashing.
void	run()

Methods inherited from class alluxio.thread.AutopsyThread

crashed, getError, setError

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

UfsJournalCheckpointThread

public UfsJournalCheckpointThread(Master master,
                                  UfsJournal journal,
                                  java.util.function.Supplier<Set<JournalSink>> journalSinks)

Creates a new instance of UfsJournalCheckpointThread.

Parameters:

master - the master to apply the journal entries to

journal - the journal

journalSinks - a supplier for journal sinks

UfsJournalCheckpointThread

public UfsJournalCheckpointThread(Master master,
                                  UfsJournal journal,
                                  long startSequence,
                                  java.util.function.Supplier<Set<JournalSink>> journalSinks)

Creates a new instance of UfsJournalCheckpointThread.

Parameters:

master - the master to apply the journal entries to

journal - the journal

startSequence - the journal start sequence

journalSinks - a supplier for journal sinks

Method Detail

awaitTermination

public void awaitTermination(boolean waitQuietPeriod)

Initiates the shutdown of this checkpointer thread, and also waits for it to finish.

Parameters:

waitQuietPeriod - whether to wait for a quiet period to pass before terminating the thread

Throws:

RuntimeException - if Thread.join() throws an InterruptedException or if run() completed exceptionally

getNextSequenceNumber

public long getNextSequenceNumber()

This should only be called after awaitTermination(boolean).

Returns:

the last edit log sequence number read plus 1

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

getCatchupState

public UfsJournalCheckpointThread.CatchupState getCatchupState()

Returns:

the state of the master process journal catchup

onError

public void onError(Throwable t)

Description copied from class: AutopsyThread

Handles the uncaught error on thread crashing. By default, just log the error for further analysis.

Overrides:

onError in class AutopsyThread

Parameters:

t - the crashing error