Skip to content

Commit 5259037

Browse files
committed
Try smaller batches
1 parent 10bdda8 commit 5259037

File tree

1 file changed

+11
-8
lines changed

1 file changed

+11
-8
lines changed

quickwit/quickwit-integration-tests/src/tests/ingest_v2_tests.rs

+11-8
Original file line numberDiff line numberDiff line change
@@ -359,14 +359,17 @@ async fn test_ingest_v2_high_throughput() {
359359
let line = json!({"body": "my dummy repeated payload"}).to_string();
360360
let num_docs = body_size / line.len();
361361
let body = std::iter::repeat_n(&line, num_docs).join("\n");
362-
let ingest_resp = ingest(
363-
&sandbox.rest_client(QuickwitService::Indexer),
364-
index_id,
365-
IngestSource::Str(body),
366-
CommitType::Auto,
367-
)
368-
.await
369-
.unwrap();
362+
let ingest_resp = sandbox
363+
.rest_client(QuickwitService::Indexer)
364+
.ingest(
365+
index_id,
366+
IngestSource::Str(body),
367+
Some(5_000_000),
368+
None,
369+
CommitType::Auto,
370+
)
371+
.await
372+
.unwrap();
370373
assert_eq!(ingest_resp.num_docs_for_processing, num_docs as u64);
371374
assert_eq!(ingest_resp.num_ingested_docs, Some(num_docs as u64));
372375
assert_eq!(ingest_resp.num_rejected_docs, Some(0));

0 commit comments

Comments
 (0)