diff --git a/control_plane/src/endpoint.rs b/control_plane/src/endpoint.rs index b19a6a1a18..3b033b32fd 100644 --- a/control_plane/src/endpoint.rs +++ b/control_plane/src/endpoint.rs @@ -290,6 +290,7 @@ impl Endpoint { conf.append("wal_log_hints", "off"); conf.append("max_replication_slots", "10"); conf.append("hot_standby", "on"); + conf.append("hot_standby_feedback", "on"); conf.append("shared_buffers", "1MB"); conf.append("fsync", "off"); conf.append("max_connections", "100"); diff --git a/test_runner/regress/test_replication_lag.py b/test_runner/regress/test_replication_lag.py index 2b638eb017..e39c8a1007 100644 --- a/test_runner/regress/test_replication_lag.py +++ b/test_runner/regress/test_replication_lag.py @@ -1,4 +1,5 @@ import threading +import time from fixtures.log_helper import log from fixtures.neon_fixtures import NeonEnv, PgBin @@ -33,6 +34,7 @@ def test_replication_lag(neon_simple_env: NeonEnv, pg_bin: PgBin): t.start() with env.endpoints.new_replica_start(origin=primary, endpoint_id="secondary") as secondary: + time.sleep(10) for _ in range(1, n_iterations): primary_lsn = primary.safe_psql_scalar( "SELECT pg_current_wal_flush_lsn()::text", log_query=False