svn commit: r1326595 - /accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java

[ecn]

Author: ecn
Date: Mon Apr 16 13:09:32 2012
New Revision: 1326595

URL: http://svn.apache.org/viewvc?rev=1326595&view=rev
Log:
ACCUMULO-534 invalidate location cache when single-update fails against a 
single tserver

Modified:
    
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java

Modified: 
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
URL: 
http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java?rev=1326595&r1=1326594&r2=1326595&view=diff
==============================================================================
--- 
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
 (original)
+++ 
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
 Mon Apr 16 13:09:32 2012
@@ -761,6 +761,7 @@ public class TabletServerBatchWriter {
               client.update(null, credentials, entry.getKey().toThrift(), 
entry.getValue().get(0).toThrift());
             } catch (NotServingTabletException e) {
               allFailures.addAll(entry.getKey().getTableId().toString(), 
entry.getValue());
+              TabletLocator.getInstance(instance, credentials, new 
Text(entry.getKey().getTableId())).invalidateCache(entry.getKey());
             } catch (ConstraintViolationException e) {
               
updatedConstraintViolations(Translator.translate(e.violationSummaries, 
Translator.TCVST));
             }