[7.x] Fix esArchiver timeout (elastic#31322) (elastic#31342)

Backports the following commits to 7.x: - Fix esArchiver timeout (elastic#31322)
mattkime · Feb 16, 2019 · eb36a8f · eb36a8f
1 parent d7ca8e4
commit eb36a8f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/es_archiver/lib/docs/__tests__/index_doc_records_stream.js b/src/es_archiver/lib/docs/__tests__/index_doc_records_stream.js
@@ -126,8 +126,8 @@ describe('esArchiver: createIndexDocRecordsStream()', () => {
     client.assertNoPendingResponses();
   });
 
-  it('sends a maximum of 1000 documents at a time', async () => {
-    const records = createPersonDocRecords(1001);
+  it('sends a maximum of 300 documents at a time', async () => {
+    const records = createPersonDocRecords(301);
     const stats = createStubStats();
     const client = createStubClient([
       async (name, params) => {
@@ -137,7 +137,7 @@ describe('esArchiver: createIndexDocRecordsStream()', () => {
       },
       async (name, params) => {
         expect(name).to.be('bulk');
-        expect(params.body.length).to.eql(999 * 2);
+        expect(params.body.length).to.eql(299 * 2);
         return { ok: true };
       },
       async (name, params) => {

diff --git a/src/es_archiver/lib/docs/index_doc_records_stream.js b/src/es_archiver/lib/docs/index_doc_records_stream.js
@@ -45,7 +45,7 @@ export function createIndexDocRecordsStream(client, stats) {
   }
 
   return new Writable({
-    highWaterMark: 1000,
+    highWaterMark: 300,
     objectMode: true,
 
     async write(record, enc, callback) {