Fix bulk indexing

tsloughter · Aug 1, 2013 · dec48d3 · dec48d3
1 parent 5f50af3
commit dec48d3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/erlastic_search.erl b/src/erlastic_search.erl
@@ -110,14 +110,14 @@ bulk_index_docs(Params, IndexTypeIdJsonTuples) ->
                              [Header, <<"\n">>, Doc, <<"\n">>];
                         ({Index, Type, Id, Doc}) when is_list(Doc) ->
                              Header = jsx:encode([
-                                                 {<<"index">>, [{[
+                                                 {<<"index">>, [
                                                                  {<<"_index">>, Index},
                                                                  {<<"_type">>, Type},
                                                                  {<<"_id">>, Id}
-                                                                 ]}]}]),
+                                                                 ]}]),
                              [Header, <<"\n">>, jsx:encode(Doc), <<"\n">>]
                      end, IndexTypeIdJsonTuples),
-    erls_resource:post(Params, <<"/_bulk">>, [], [], Body, []).
+    erls_resource:post(Params, <<"/_bulk">>, [], [], iolist_to_binary(Body), []).
 
 
 %%--------------------------------------------------------------------