Guest User

Untitled

a guest
Aug 30th, 2016
96
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.87 KB | None | 0 0
  1. 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
  2. index 95db256..3886ee1 100644
  3. --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java
  4. +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java
  5. @@ -342,6 +342,10 @@ public class ProcedureExecutor<TEnvironment> {
  6. nonceKey = proc.getNonceKey();
  7. procId = proc.getProcId();
  8.  
  9. + if (proc.getOwner() == null) {
  10. + LOG.error("Procedure " + proc + " doesn't have owner");
  11. + continue;
  12. + }
  13. if (!proc.hasParent()) {
  14. assert !proc.isFinished() : "unexpected finished procedure";
  15. rollbackStack.put(proc.getProcId(), new RootProcedureState());
Advertisement
Add Comment
Please, Sign In to add comment