diff --git a/pageserver/src/config.rs b/pageserver/src/config.rs index a6a11910c9..4d1575a21c 100644 --- a/pageserver/src/config.rs +++ b/pageserver/src/config.rs @@ -1224,7 +1224,7 @@ background_task_maximum_delay = '334 s' control_plane_api_token: None, control_plane_emergency_mode: false, heatmap_upload_concurrency: defaults::DEFAULT_HEATMAP_UPLOAD_CONCURRENCY, - ingest_batch_size: 1, + ingest_batch_size: 100, }, "Should be able to parse all basic config values correctly" ); diff --git a/pageserver/src/walingest.rs b/pageserver/src/walingest.rs index 4dfb8745ce..bd8dcfad86 100644 --- a/pageserver/src/walingest.rs +++ b/pageserver/src/walingest.rs @@ -2204,7 +2204,7 @@ mod tests { let path = "test_data/sk_wal_segment_from_pgbench"; let wal_segment_path = format!("{path}/000000010000000000000001.zst"); let startpoint = Lsn::from_hex("14AEC08").unwrap(); - let endpoint = Lsn::from_hex("1FFFF98").unwrap(); + let _endpoint = Lsn::from_hex("1FFFF98").unwrap(); // Bootstrap a real timeline. We can't use create_test_timeline because // it doesn't create a real checkpoint, and Walingest::new tries to parse @@ -2243,7 +2243,7 @@ mod tests { let mut walingest = WalIngest::new(tline.as_ref(), startpoint, &ctx) .await .unwrap(); - let mut modification = tline.begin_modification(endpoint); + let mut modification = tline.begin_modification(startpoint); let mut decoded = DecodedWALRecord::default(); println!("decoding {} bytes", bytes.len() - xlogoff);