in Coprozessor setzen postBatchMutate

Question

Ich möchte einen neuen Schlüssel-Wert für die aktuelle Zeile in BaseRegionObserver.postBatchMutate, aber ich steckte in MVCC und ein Deadlock auftritt. Hier ist mein Code:

@Override 
public void postBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, 
          MiniBatchOperationInProgress<Mutation> miniBatchOp) throws IOException { 
    for (int i = 0 ; i < miniBatchOp.size(); i ++) { 
     Put put = null; 
     Mutation op = miniBatchOp.getOperation(i); 
     if (! (op instanceof Put)) 
      continue; 

     put = (Put) miniBatchOp.getOperation(0); 

     if (put.has(Bytes.toBytes("m"), Bytes.toBytes("id"))) 
      return; 

     Put put1 = new Put(put.getRow()); 
     put1.addColumn(Bytes.toBytes("m"), Bytes.toBytes("id"), 
      Bytes.toBytes(String.valueOf(UUID.randomUUID()))); 

     c.getEnvironment().getRegion().put(put1); 

    } 
} 

können Sie finden diese in der Ausgabe WARN Nachricht wiederholen:

regionserver.MultiVersionConcurrencyControl WARNEN: STUCK: MultiVersionConcurrencyControl {readPoint = 3, writePoint = 5}

Answer 1

Möchten Sie Deinen Code posten? Sie können die Region immer vom Coprozessor holen und manuell einen Put ausführen. Es ist mir nicht klar, was deine Fehlersemantik ist ... Müssen beide erfolgreich sein oder scheitern?