Remove unused object.

slojo404 · Jun 24, 2011 · a6a85dc · a6a85dc
1 parent 30ac171
commit a6a85dc
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/src/main/java/org/elasticsearch/flume/ElasticSearchSink.java b/src/main/java/org/elasticsearch/flume/ElasticSearchSink.java
@@ -59,7 +59,6 @@ public class ElasticSearchSink extends EventSink.Base {
     @Override
     public void append(Event e) throws IOException {
         // TODO strategize the name of the index, so that logs based on day can go to individula indexes, allowing simple cleanup by deleting older days indexes in ES
-        XContentParser parser = null;
         byte[] data = e.getBody();
         try {
             XContentBuilder builder = jsonBuilder()
@@ -84,8 +83,6 @@ public void append(Event e) throws IOException {
         } catch (Exception ex) {
             LOG.error(String.format("Error Processing event: %s", new String(data)),ex);
             eventErrorCount.incrementAndGet();
-        } finally {
-            if (parser != null) parser.close();
         }
     }