fix data leak BRC when dealing with Hive data

relates to elastic#66 elastic#85 elastic#81 elastic#69
williamrandolph · Nov 7, 2013 · 56fde61 · 56fde61
1 parent 45e95ab
commit 56fde61
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/org/elasticsearch/hadoop/rest/BufferedRestClient.java b/src/main/java/org/elasticsearch/hadoop/rest/BufferedRestClient.java
@@ -122,6 +122,7 @@ public void writeProcessedToIndex(BytesArray ba) throws IOException {
         Assert.isTrue(ba.size() > 0, "no data given");
 
         lazyInitWriting();
+        objectAlreadySerialized.clear();
         objectAlreadySerialized.add(ba);
         doWriteToIndex(objectAlreadySerialized);
     }