github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 17:59:23 -04:00
Code Issues Projects Releases Packages Wiki Activity

Revert "[7.0] Fix esArchiver timeout (#31322) (#31343)"

Browse source 
This reverts commit 6fe20d2105.
This commit is contained in:
spalger 2019-02-17 03:38:54 -08:00
parent c44d918b17
commit 51f0d32b89
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/es_archiver/lib/docs/__tests__/index_doc_records_stream.js
View file

@ -126,8 +126,8 @@ describe('esArchiver: createIndexDocRecordsStream()', () => {
client.assertNoPendingResponses();
});
it('sends a maximum of 300 documents at a time', async () => {
const records = createPersonDocRecords(301);
it('sends a maximum of 1000 documents at a time', async () => {
const records = createPersonDocRecords(1001);
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(299 * 2);
expect(params.body.length).to.eql(999 * 2);
return { ok: true };
},
async (name, params) => {

2
src/es_archiver/lib/docs/index_doc_records_stream.js
View file

@ -45,7 +45,7 @@ export function createIndexDocRecordsStream(client, stats) {
}
return new Writable({
highWaterMark: 300,
highWaterMark: 1000,
objectMode: true,
async write(record, enc, callback) {