Author: ecn
Date: Mon Dec 17 19:23:06 2012
New Revision: 1423102
URL: http://svn.apache.org/viewvc?rev=1423102&view=rev
Log:
ACCUMUL-909 move null-pointer check, merge to trunk
Modified:
accumulo/trunk/ (props changed)
accumulo/trunk/assemble/ (props changed)
accumulo/trunk/core/ (props changed)
accumulo/trunk/fate/src/main/java/org/apache/accumulo/fate/ZooStore.java
(props changed)
accumulo/trunk/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooSession.java
(props changed)
accumulo/trunk/server/ (props changed)
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
accumulo/trunk/src/ (props changed)
Propchange: accumulo/trunk/
------------------------------------------------------------------------------
Merged /accumulo/branches/1.4/src:r1423032
Merged /accumulo/branches/1.4:r1423032
Propchange: accumulo/trunk/assemble/
------------------------------------------------------------------------------
Merged /accumulo/branches/1.4/src/assemble:r1423032
Merged /accumulo/branches/1.4/assemble:r1423032
Propchange: accumulo/trunk/core/
------------------------------------------------------------------------------
Merged /accumulo/branches/1.4/core:r1423032
Merged /accumulo/branches/1.4/src/core:r1423032
Propchange:
accumulo/trunk/fate/src/main/java/org/apache/accumulo/fate/ZooStore.java
------------------------------------------------------------------------------
Merged
/accumulo/branches/1.4/fate/src/main/java/org/apache/accumulo/fate/ZooStore.java:r1423032
Merged
/accumulo/branches/1.4/src/fate/src/main/java/org/apache/accumulo/fate/ZooStore.java:r1423032
Propchange:
accumulo/trunk/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooSession.java
------------------------------------------------------------------------------
Merged
/accumulo/branches/1.4/src/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooSession.java:r1423032
Merged
/accumulo/branches/1.4/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooSession.java:r1423032
Propchange: accumulo/trunk/server/
------------------------------------------------------------------------------
Merged /accumulo/branches/1.4/server:r1423032
Merged /accumulo/branches/1.4/src/server:r1423032
Modified:
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
URL:
http://svn.apache.org/viewvc/accumulo/trunk/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java?rev=1423102&r1=1423101&r2=1423102&view=diff
==============================================================================
---
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
(original)
+++
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
Mon Dec 17 19:23:06 2012
@@ -980,13 +980,15 @@ public class TabletServer extends Abstra
String oldThreadName = Thread.currentThread().getName();
try {
- runState.set(ScanRunState.RUNNING);
- Thread.currentThread().setName("Client: " + session.client + " User:
" + session.user + " Start: " + session.startTime + " Table: ");
if (isCancelled() || session == null)
return;
TableConfiguration acuTableConf =
ServerConfiguration.getTableConfiguration(instance,
session.threadPoolExtent.getTableId().toString());
long maxResultsSize =
acuTableConf.getMemoryInBytes(Property.TABLE_SCAN_MAXMEM);
+
+ runState.set(ScanRunState.RUNNING);
+ Thread.currentThread().setName("Client: " + session.client + " User:
" + session.user + " Start: " + session.startTime + " Table: ");
+
long bytesAdded = 0;
long maxScanTime = 4000;
Propchange: accumulo/trunk/src/
------------------------------------------------------------------------------
Merged /accumulo/branches/1.4/src:r1423032
Merged /accumulo/branches/1.4/src/src:r1423032
Merged /accumulo/branches/1.4:r1423032