accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject svn commit: r1351457 - in /accumulo/trunk: ./ core/ server/ server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java src/
Date Mon, 18 Jun 2012 18:49:21 GMT
Author: kturner
Date: Mon Jun 18 18:49:21 2012
New Revision: 1351457

URL: http://svn.apache.org/viewvc?rev=1351457&view=rev
Log:
ACCUMULO-637 closed batch writer before continuous ingest exits (merged from 1.4)

Modified:
    accumulo/trunk/   (props changed)
    accumulo/trunk/core/   (props changed)
    accumulo/trunk/server/   (props changed)
    accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java
    accumulo/trunk/src/   (props changed)

Propchange: accumulo/trunk/
------------------------------------------------------------------------------
  Merged /accumulo/trunk/src:r1350779
  Merged /accumulo/branches/1.4/src:r1351425
  Merged /accumulo/branches/1.4:r1351425

Propchange: accumulo/trunk/core/
------------------------------------------------------------------------------
  Merged /accumulo/trunk/src/core:r1350779
  Merged /accumulo/branches/1.4/core:r1351425
  Merged /accumulo/branches/1.4/src/core:r1351425

Propchange: accumulo/trunk/server/
------------------------------------------------------------------------------
  Merged /accumulo/branches/1.4/server:r1351425
  Merged /accumulo/trunk/src/server:r1350779
  Merged /accumulo/branches/1.4/src/server:r1351425

Modified: accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java?rev=1351457&r1=1351456&r2=1351457&view=diff
==============================================================================
--- accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java
(original)
+++ accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java
Mon Jun 18 18:49:21 2012
@@ -189,6 +189,8 @@ public class ContinuousIngest {
       if (count >= num)
         break out;
     }
+    
+    bw.close();
   }
   
   private static long flush(BatchWriter bw, long count, final int flushInterval, long lastFlushTime)
throws MutationsRejectedException {

Propchange: accumulo/trunk/src/
------------------------------------------------------------------------------
  Merged /accumulo/branches/1.4/src:r1351425
  Merged /accumulo/trunk:r1350779
  Merged /accumulo/branches/1.4/src/src:r1351425



Mime
View raw message