Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java
- index 95db256..3886ee1 100644
- --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java
- +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java
- @@ -342,6 +342,10 @@ public class ProcedureExecutor<TEnvironment> {
- nonceKey = proc.getNonceKey();
- procId = proc.getProcId();
- + if (proc.getOwner() == null) {
- + LOG.error("Procedure " + proc + " doesn't have owner");
- + continue;
- + }
- if (!proc.hasParent()) {
- assert !proc.isFinished() : "unexpected finished procedure";
- rollbackStack.put(proc.getProcId(), new RootProcedureState());
Advertisement
Add Comment
Please, Sign In to add comment