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

[6.7] Fix esArchiver timeout (#31322) (#31344)

Browse source 
Backports the following commits to 6.7:
 - Fix esArchiver timeout  (#31322)
This commit is contained in:
Spencer 2019-02-15 20:05:00 -08:00 • committed by GitHub
parent 0166043917
commit bc5e1a81e5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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 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) => {

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: 1000,
highWaterMark: 300,
objectMode: true,
async write(record, enc, callback) {