HBASE-25057: Fix typo memeber (#2414)
Signed-off-by: Viraj Jasani <vjasani@apache.org> Signed-off-by: Duo Zhang <zhangduo@apache.org> Signed-off-by: Jan Hentschel <jan.hentschel@ultratendency.com>
This commit is contained in:
parent
16831ec515
commit
6371914adb
|
@ -116,7 +116,7 @@ public class LogRollRegionServerProcedureManager extends RegionServerProcedureMa
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* If in a running state, creates the specified subprocedure for handling a backup procedure.
|
* If in a running state, creates the specified subprocedure for handling a backup procedure.
|
||||||
* @return Subprocedure to submit to the ProcedureMemeber.
|
* @return Subprocedure to submit to the ProcedureMember.
|
||||||
*/
|
*/
|
||||||
public Subprocedure buildSubprocedure(byte[] data) {
|
public Subprocedure buildSubprocedure(byte[] data) {
|
||||||
// don't run a backup if the parent is stop(ping)
|
// don't run a backup if the parent is stop(ping)
|
||||||
|
|
|
@ -39,7 +39,7 @@ import org.slf4j.LoggerFactory;
|
||||||
* member), {@link #insideBarrier()} (execute while globally barriered and release barrier) and
|
* member), {@link #insideBarrier()} (execute while globally barriered and release barrier) and
|
||||||
* {@link #cleanup(Exception)} (release state associated with subprocedure.)
|
* {@link #cleanup(Exception)} (release state associated with subprocedure.)
|
||||||
*
|
*
|
||||||
* When submitted to a ProcedureMemeber, the call method is executed in a separate thread.
|
* When submitted to a ProcedureMember, the call method is executed in a separate thread.
|
||||||
* Latches are use too block its progress and trigger continuations when barrier conditions are
|
* Latches are use too block its progress and trigger continuations when barrier conditions are
|
||||||
* met.
|
* met.
|
||||||
*
|
*
|
||||||
|
@ -147,7 +147,7 @@ abstract public class Subprocedure implements Callable<Void> {
|
||||||
* Execute the Subprocedure {@link #acquireBarrier()} and {@link #insideBarrier()} methods
|
* Execute the Subprocedure {@link #acquireBarrier()} and {@link #insideBarrier()} methods
|
||||||
* while keeping some state for other threads to access.
|
* while keeping some state for other threads to access.
|
||||||
*
|
*
|
||||||
* This would normally be executed by the ProcedureMemeber when a acquire message comes from the
|
* This would normally be executed by the ProcedureMember when a acquire message comes from the
|
||||||
* coordinator. Rpcs are used to spend message back to the coordinator after different phases
|
* coordinator. Rpcs are used to spend message back to the coordinator after different phases
|
||||||
* are executed. Any exceptions caught during the execution (except for InterruptedException) get
|
* are executed. Any exceptions caught during the execution (except for InterruptedException) get
|
||||||
* converted and propagated to coordinator via {@link ProcedureMemberRpcs#sendMemberAborted(
|
* converted and propagated to coordinator via {@link ProcedureMemberRpcs#sendMemberAborted(
|
||||||
|
|
|
@ -132,7 +132,7 @@ public class RegionServerFlushTableProcedureManager extends RegionServerProcedur
|
||||||
*
|
*
|
||||||
* @param table
|
* @param table
|
||||||
* @param family
|
* @param family
|
||||||
* @return Subprocedure to submit to the ProcedureMemeber.
|
* @return Subprocedure to submit to the ProcedureMember.
|
||||||
*/
|
*/
|
||||||
public Subprocedure buildSubprocedure(String table, String family) {
|
public Subprocedure buildSubprocedure(String table, String family) {
|
||||||
|
|
||||||
|
|
|
@ -150,7 +150,7 @@ public class RegionServerSnapshotManager extends RegionServerProcedureManager {
|
||||||
* the snapshot verification step.
|
* the snapshot verification step.
|
||||||
*
|
*
|
||||||
* @param snapshot
|
* @param snapshot
|
||||||
* @return Subprocedure to submit to the ProcedureMemeber.
|
* @return Subprocedure to submit to the ProcedureMember.
|
||||||
*/
|
*/
|
||||||
public Subprocedure buildSubprocedure(SnapshotDescription snapshot) {
|
public Subprocedure buildSubprocedure(SnapshotDescription snapshot) {
|
||||||
|
|
||||||
|
|
|
@ -85,7 +85,7 @@ public class SimpleRSProcedureManager extends RegionServerProcedureManager {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* If in a running state, creates the specified subprocedure for handling a procedure.
|
* If in a running state, creates the specified subprocedure for handling a procedure.
|
||||||
* @return Subprocedure to submit to the ProcedureMemeber.
|
* @return Subprocedure to submit to the ProcedureMember.
|
||||||
*/
|
*/
|
||||||
public Subprocedure buildSubprocedure(String name) {
|
public Subprocedure buildSubprocedure(String name) {
|
||||||
|
|
||||||
|
|
|
@ -204,7 +204,7 @@ public class TestProcedureMember {
|
||||||
new Answer<Void>() {
|
new Answer<Void>() {
|
||||||
@Override
|
@Override
|
||||||
public Void answer(InvocationOnMock invocation) throws Throwable {
|
public Void answer(InvocationOnMock invocation) throws Throwable {
|
||||||
throw new IOException("Forced IOException in memeber prepare");
|
throw new IOException("Forced IOException in member prepare");
|
||||||
}
|
}
|
||||||
}).when(mockMemberComms).sendMemberAcquired(any());
|
}).when(mockMemberComms).sendMemberAcquired(any());
|
||||||
|
|
||||||
|
@ -288,7 +288,7 @@ public class TestProcedureMember {
|
||||||
new Answer<Void>() {
|
new Answer<Void>() {
|
||||||
@Override
|
@Override
|
||||||
public Void answer(InvocationOnMock invocation) throws Throwable {
|
public Void answer(InvocationOnMock invocation) throws Throwable {
|
||||||
throw new IOException("Forced IOException in memeber prepare");
|
throw new IOException("Forced IOException in member prepare");
|
||||||
}
|
}
|
||||||
}).when(spySub).insideBarrier();
|
}).when(spySub).insideBarrier();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue