Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Accumulo, mail # dev - Re: svn commit: r1398283 - in /accumulo/branches/1.4: ./ src/ src/core/ src/server/ src/server/src/main/java/org/apache/accumulo/server/tabletserver/ src/server/src/test/java/org/apache/accumulo/server/tabletserver/
Keith Turner
2012-10-15, 17:07
Copy link to this message
-
Re: svn commit: r1398283 - in /accumulo/branches/1.4: ./ src/ src/core/ src/server/ src/server/src/main/java/org/apache/accumulo/server/tabletserver/ src/server/src/test/java/org/apache/accumulo/server/tabletserver/
Keith Turner 2012-10-15, 17:09
On Mon, Oct 15, 2012 at 1:07 PM, Keith Turner <[EMAIL PROTECTED]> wrote:
> Should probably clear recently unloaded set when a tablets are loaded
>

I didn't say what I meant... do not need to clean the entire set...
just remove the tablet that was just loaded

> On Mon, Oct 15, 2012 at 9:28 AM,  <[EMAIL PROTECTED]> wrote:
>> Author: ecn
>> Date: Mon Oct 15 13:28:25 2012
>> New Revision: 1398283
>>
>> URL: http://svn.apache.org/viewvc?rev=1398283&view=rev
>> Log:
>> ACCUMULO-774 merge to 1.4 branch
>>
>> Added:
>>     accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/SimpleLRUCache.java
>>       - copied unchanged from r1398282, accumulo/trunk/server/src/main/java/org/apache/accumulo/server/tabletserver/SimpleLRUCache.java
>>     accumulo/branches/1.4/src/server/src/test/java/org/apache/accumulo/server/tabletserver/SimpleLRUCacheTest.java
>>       - copied, changed from r1397990, accumulo/trunk/server/src/test/java/org/apache/accumulo/server/tabletserver/SimpleLRUCacheTest.java
>> Modified:
>>     accumulo/branches/1.4/   (props changed)
>>     accumulo/branches/1.4/src/   (props changed)
>>     accumulo/branches/1.4/src/core/   (props changed)
>>     accumulo/branches/1.4/src/server/   (props changed)
>>     accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
>>
>> Propchange: accumulo/branches/1.4/
>> ------------------------------------------------------------------------------
>>   Merged /accumulo/trunk:r1397928,1397975,1397990
>>
>> Propchange: accumulo/branches/1.4/src/
>> ------------------------------------------------------------------------------
>>   Merged /accumulo/trunk/src:r1397928,1397975,1397990
>>   Merged /accumulo/trunk:r1397928,1397975,1397990,1398090
>>
>> Propchange: accumulo/branches/1.4/src/core/
>> ------------------------------------------------------------------------------
>>   Merged /accumulo/trunk/src/core:r1397928,1397975,1397990
>>   Merged /accumulo/trunk/core:r1397928,1397975,1397990,1398090
>>
>> Propchange: accumulo/branches/1.4/src/server/
>> ------------------------------------------------------------------------------
>>   Merged /accumulo/trunk/src/server:r1397928,1397975,1397990
>>   Merged /accumulo/trunk/server:r1397928,1397975,1397990,1398090
>>
>> Modified: accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
>> URL: http://svn.apache.org/viewvc/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java?rev=1398283&r1=1398282&r2=1398283&view=diff
>> =============================================================================>> --- accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java (original)
>> +++ accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java Mon Oct 15 13:28:25 2012
>> @@ -2258,8 +2258,10 @@ public class TabletServer extends Abstra
>>        if (t == null) {
>>          // Tablet has probably been recently unloaded: repeated master
>>          // unload request is crossing the successful unloaded message
>> -        log.info("told to unload tablet that was not being served " + extent);
>> -        enqueueMasterMessage(new TabletStatusMessage(TabletLoadState.UNLOAD_FAILURE_NOT_SERVING, extent));
>> +        if (!recentlyUnloadedCache.contains(extent)) {
>> +          log.info("told to unload tablet that was not being served " + extent);
>> +          enqueueMasterMessage(new TabletStatusMessage(TabletLoadState.UNLOAD_FAILURE_NOT_SERVING, extent));
>> +        }
>>          return;
>>        }
>>
>> @@ -2279,6 +2281,7 @@ public class TabletServer extends Abstra
>>
>>        // stop serving tablet - client will get not serving tablet
>>        // exceptions
>> +      recentlyUnloadedCache.add(extent);
>>        onlineTablets.remove(extent);
>>
>>        try {
>> @@ -2501,6 +2504,7 @@ public class TabletServer extends Abstra