src/main/java/org/embulk/output/elasticsearch/ElasticsearchOutputPluginDelegate.java in embulk-output-elasticsearch-0.4.1 vs src/main/java/org/embulk/output/elasticsearch/ElasticsearchOutputPluginDelegate.java in embulk-output-elasticsearch-0.4.2

@@ -233,10 +233,10 @@
                 .add(new JacksonAllInObjectScope(formatter), new JacksonTopLevelValueLocator("record"))
                 .build();
     }
 
     @Override  // Overridden from |RecordBufferBuildable|
-    public RecordBuffer buildRecordBuffer(PluginTask task)
+    public RecordBuffer buildRecordBuffer(PluginTask task, Schema schema, int taskIndex)
     {
         Jetty92RetryHelper retryHelper = createRetryHelper(task);
         return new ElasticsearchRecordBuffer("records", task, retryHelper);
     }