rewrite with custom json serializer

.github/workflows/cloud-regress.yml

@@ -14,6 +14,11 @@ defaults:
   run:
     shell: bash -euxo pipefail {0}
 
+concurrency:
+  # Allow only one workflow
+  group: ${{ github.workflow }}
+  cancel-in-progress: true
+
 permissions:
   id-token: write # aws-actions/configure-aws-credentials
   statuses: write
@@ -28,10 +33,9 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        pg-version: [17]
+        pg-version: [16, 17]
 
-    #runs-on: us-east-2
-    runs-on: small
+    runs-on: us-east-2
     container:
       image: ghcr.io/neondatabase/build-tools:pinned-bookworm
       credentials:
@@ -55,7 +59,6 @@ jobs:
         run: |
           cd "vendor/postgres-v${PG_VERSION}"
           patch -p1 < "../../compute/patches/cloud_regress_pg${PG_VERSION}.patch"
-          patch -p1 < "../../compute/patches/cloud_regress_pg17_495.patch"
 
       - name: Generate a random password
         id: pwgen

Cargo.lock

@@ -5205,6 +5205,7 @@ dependencies = [
  "rustls 0.23.18",
  "rustls-native-certs 0.8.0",
  "rustls-pemfile 2.1.1",
+ "ryu",
  "scopeguard",
  "serde",
  "serde_json",

compute/patches/cloud_regress_pg17_ha_plus.patch

@@ -1,129 +0,0 @@
-diff --git a/src/test/regress/sql/box.sql b/src/test/regress/sql/box.sql
-index 249636c76c3..540c2b54dda 100644
---- a/src/test/regress/sql/box.sql
-+++ b/src/test/regress/sql/box.sql
-@@ -196,7 +196,7 @@ CREATE TABLE quad_box_tbl (id int, b box);
- 
- INSERT INTO quad_box_tbl
-   SELECT (x - 1) * 100 + y, box(point(x * 10, y * 10), point(x * 10 + 5, y * 10 + 5))
--  FROM generate_series(1, 95 * 100) x,
-+  FROM generate_series(1, 100) x,
-        generate_series(1, 95 * 100) y;
- 
- -- insert repeating data to test allTheSame
-diff --git a/src/test/regress/sql/partition_join.sql b/src/test/regress/sql/partition_join.sql
-index 3ca8a2d6090..a8e40f906c4 100644
---- a/src/test/regress/sql/partition_join.sql
-+++ b/src/test/regress/sql/partition_join.sql
-@@ -533,7 +533,7 @@ create temp table prtx2_3 partition of prtx2 for values from (21) to (31);
- insert into prtx1 select 1 + i%30, i, i
-   from generate_series(1, 95 * 1000) i;
- insert into prtx2 select 1 + i%30, i, i
--  from generate_series(1, 95 * 500) i, generate_series(1, 95 * 10) j;
-+  from generate_series(1, 500) i, generate_series(1, 95 * 10) j;
- create index on prtx2 (b);
- create index on prtx2 (c);
- analyze prtx1;
-diff --git a/src/test/regress/sql/partition_prune.sql b/src/test/regress/sql/partition_prune.sql
-index 82ac39d5dc8..bef0a891ade 100644
---- a/src/test/regress/sql/partition_prune.sql
-+++ b/src/test/regress/sql/partition_prune.sql
-@@ -1274,9 +1274,9 @@ select
-   case c when 0 then null else 3 end,
-   case d when 0 then null else 4 end
- from
--  generate_series(0, 95 * 1) a,
--  generate_series(0, 95 * 1) b,
--  generate_series(0, 95 * 1) c,
-+  generate_series(0, 1) a,
-+  generate_series(0, 1) b,
-+  generate_series(0, 1) c,
-   generate_series(0, 95 * 1) d;
- 
- -- Ensure partition pruning works correctly for each combination of IS NULL
-diff --git a/src/test/regress/sql/polygon.sql b/src/test/regress/sql/polygon.sql
-index d39a2b4e8f8..2d862985510 100644
---- a/src/test/regress/sql/polygon.sql
-+++ b/src/test/regress/sql/polygon.sql
-@@ -42,7 +42,7 @@ CREATE TABLE quad_poly_tbl (id int, p polygon);
- 
- INSERT INTO quad_poly_tbl
- 	SELECT (x - 1) * 100 + y, polygon(circle(point(x * 10, y * 10), 1 + (x + y) % 10))
--	FROM generate_series(1, 95 * 100) x,
-+	FROM generate_series(1, 100) x,
- 		 generate_series(1, 95 * 100) y;
- 
- INSERT INTO quad_poly_tbl
-diff --git a/src/test/regress/sql/rangetypes.sql b/src/test/regress/sql/rangetypes.sql
-index b51d6c405c2..4138418c7a6 100644
---- a/src/test/regress/sql/rangetypes.sql
-+++ b/src/test/regress/sql/rangetypes.sql
-@@ -314,13 +314,13 @@ select count(*) from test_range_gist where ir -|- int4multirange(int4range(100,2
- create table test_range_spgist(ir int4range);
- create index test_range_spgist_idx on test_range_spgist using spgist (ir);
- 
--insert into test_range_spgist select int4range(g, g+10) from generate_series(1, 95 * 2000) g;
--insert into test_range_spgist select 'empty'::int4range from generate_series(1, 95 * 500) g;
--insert into test_range_spgist select int4range(g, g+10000) from generate_series(1, 95 * 1000) g;
--insert into test_range_spgist select 'empty'::int4range from generate_series(1, 95 * 500) g;
--insert into test_range_spgist select int4range(NULL,g*10,'(]') from generate_series(1, 95 * 100) g;
--insert into test_range_spgist select int4range(g*10,NULL,'(]') from generate_series(1, 95 * 100) g;
--insert into test_range_spgist select int4range(g, g+10) from generate_series(1, 95 * 2000) g;
-+insert into test_range_spgist select int4range(g, g+10) from generate_series(1, 0.1 * 95 * 2000) g;
-+insert into test_range_spgist select 'empty'::int4range from generate_series(1, 0.1 * 95 * 500) g;
-+insert into test_range_spgist select int4range(g, g+10000) from generate_series(1, 0.1 * 95 * 1000) g;
-+insert into test_range_spgist select 'empty'::int4range from generate_series(1, 0.1 * 95 * 500) g;
-+insert into test_range_spgist select int4range(NULL,g*10,'(]') from generate_series(1, 0.1 * 95 * 100) g;
-+insert into test_range_spgist select int4range(g*10,NULL,'(]') from generate_series(1, 0.1 * 95 * 100) g;
-+insert into test_range_spgist select int4range(g, g+10) from generate_series(1, 0.1 * 95 * 2000) g;
- 
- -- first, verify non-indexed results
- SET enable_seqscan    = t;
-diff --git a/src/test/regress/sql/spgist.sql b/src/test/regress/sql/spgist.sql
-index 0c4f24e1d49..61e53375539 100644
---- a/src/test/regress/sql/spgist.sql
-+++ b/src/test/regress/sql/spgist.sql
-@@ -16,9 +16,9 @@ vacuum spgist_point_tbl;
- 
- -- Insert more data, to make the index a few levels deep.
- insert into spgist_point_tbl (id, p)
--select g,      point(g*10, g*10) from generate_series(1, 95 * 10000) g;
-+select g,      point(g*10, g*10) from generate_series(1, 0.1 * 95 * 10000) g;
- insert into spgist_point_tbl (id, p)
--select g+100000, point(g*10+1, g*10+1) from generate_series(1, 95 * 10000) g;
-+select g+100000, point(g*10+1, g*10+1) from generate_series(1, 0.1 * 95 * 10000) g;
- 
- -- To test vacuum, delete some entries from all over the index.
- delete from spgist_point_tbl where id % 2 = 1;
-@@ -37,8 +37,8 @@ vacuum spgist_point_tbl;
- create table spgist_box_tbl(id serial, b box);
- insert into spgist_box_tbl(b)
- select box(point(i,j),point(i+s,j+s))
--  from generate_series(1, 95 * 100,5) i,
--       generate_series(1, 95 * 100,5) j,
-+  from generate_series(1,100,5) i,
-+       generate_series(1,100,5) j,
-        generate_series(1, 95 * 10) s;
- create index spgist_box_idx on spgist_box_tbl using spgist (b);
- 
-@@ -86,6 +86,6 @@ create unlogged table spgist_unlogged_tbl(id serial, b box);
- create index spgist_unlogged_idx on spgist_unlogged_tbl using spgist (b);
- insert into spgist_unlogged_tbl(b)
- select box(point(i,j))
--  from generate_series(1, 95 * 100,5) i,
-+  from generate_series(1,100,5) i,
-        generate_series(1, 95 * 10,5) j;
- -- leave this table around, to help in testing dump/restore
-diff --git a/src/test/regress/sql/tuplesort.sql b/src/test/regress/sql/tuplesort.sql
-index fa762f26ac7..7a1fd619eba 100644
---- a/src/test/regress/sql/tuplesort.sql
-+++ b/src/test/regress/sql/tuplesort.sql
-@@ -276,7 +276,7 @@ ROLLBACK;
- CREATE TEMP TABLE test_mark_restore(col1 int, col2 int, col12 int);
- -- need a few duplicates for mark/restore to matter
- INSERT INTO test_mark_restore(col1, col2, col12)
--   SELECT a.i, b.i, a.i * b.i FROM generate_series(1, 95 * 500) a(i), generate_series(1, 95 * 5) b(i);
-+   SELECT a.i, b.i, a.i * b.i FROM generate_series(1, 500) a(i), generate_series(1, 95 * 5) b(i);
- 
- BEGIN;
- 

compute/patches/cloud_regress_pg17_ha_plus2.patch

@@ -1,593 +0,0 @@
-diff --git a/src/test/regress/sql/box.sql b/src/test/regress/sql/box.sql
-index 249636c76c3..540c2b54dda 100644
---- a/src/test/regress/sql/box.sql
-+++ b/src/test/regress/sql/box.sql
-@@ -196,7 +196,7 @@ CREATE TABLE quad_box_tbl (id int, b box);
- 
- INSERT INTO quad_box_tbl
-   SELECT (x - 1) * 100 + y, box(point(x * 10, y * 10), point(x * 10 + 5, y * 10 + 5))
--  FROM generate_series(1, 95 * 100) x,
-+  FROM generate_series(1, 100) x,
-        generate_series(1, 95 * 100) y;
- 
- -- insert repeating data to test allTheSame
-diff --git a/src/test/regress/sql/brin.sql b/src/test/regress/sql/brin.sql
-index 39d3cd7821a..86efbb72609 100644
---- a/src/test/regress/sql/brin.sql
-+++ b/src/test/regress/sql/brin.sql
-@@ -476,7 +476,7 @@ CREATE TABLE brintest_3 (a text, b text, c text, d text);
- 
- -- long random strings (~2000 chars each, so ~6kB for min/max on two
- -- columns) to trigger toasting
--WITH rand_value AS (SELECT string_agg(fipshash(i::text),'') AS val FROM generate_series(1, 95 * 60) s(i))
-+WITH rand_value AS (SELECT string_agg(fipshash(i::text),'') AS val FROM generate_series(1,60) s(i))
- INSERT INTO brintest_3
- SELECT val, val, val, val FROM rand_value;
- 
-@@ -495,7 +495,7 @@ VACUUM brintest_3;
- -- retry insert with a different random-looking (but deterministic) value
- -- the value is different, and so should replace either min or max in the
- -- brin summary
--WITH rand_value AS (SELECT string_agg(fipshash((-i)::text),'') AS val FROM generate_series(1, 95 * 60) s(i))
-+WITH rand_value AS (SELECT string_agg(fipshash((-i)::text),'') AS val FROM generate_series(1,60) s(i))
- INSERT INTO brintest_3
- SELECT val, val, val, val FROM rand_value;
- 
-diff --git a/src/test/regress/sql/brin_multi.sql b/src/test/regress/sql/brin_multi.sql
-index b7f7a9e8803..b1a109fe07f 100644
---- a/src/test/regress/sql/brin_multi.sql
-+++ b/src/test/regress/sql/brin_multi.sql
-@@ -612,7 +612,7 @@ CREATE TABLE brin_date_test(a DATE);
- INSERT INTO brin_date_test SELECT '4713-01-01 BC'::date + i FROM generate_series(1, 95 * 30) s(i);
- 
- -- insert values close to date minimum
--INSERT INTO brin_date_test SELECT '5874897-12-01'::date + i FROM generate_series(1, 95 * 30) s(i);
-+INSERT INTO brin_date_test SELECT '5874897-12-01'::date + i FROM generate_series(1, 30) s(i);
- 
- CREATE INDEX ON brin_date_test USING brin (a date_minmax_multi_ops) WITH (pages_per_range=1);
- 
-diff --git a/src/test/regress/sql/btree_index.sql b/src/test/regress/sql/btree_index.sql
-index d0d86db1667..88a752264a0 100644
---- a/src/test/regress/sql/btree_index.sql
-+++ b/src/test/regress/sql/btree_index.sql
-@@ -267,7 +267,7 @@ VACUUM delete_test_table;
- --
- -- The vacuum above should've turned the leaf page into a fast root. We just
- -- need to insert some rows to cause the fast root page to split.
--INSERT INTO delete_test_table SELECT i, 1, 2, 3 FROM generate_series(1, 95 * 1000) i;
-+INSERT INTO delete_test_table SELECT i, 1, 2, 3 FROM generate_series(1,1000) i;
- 
- -- Test unsupported btree opclass parameters
- create index on btree_tall_tbl (id int4_ops(foo=1));
-diff --git a/src/test/regress/sql/create_table.sql b/src/test/regress/sql/create_table.sql
-index 13006372064..1fd4cbfa7ef 100644
---- a/src/test/regress/sql/create_table.sql
-+++ b/src/test/regress/sql/create_table.sql
-@@ -47,7 +47,7 @@ DEALLOCATE select1;
- -- (temporarily hide query, to avoid the long CREATE TABLE stmt)
- \set ECHO none
- SELECT 'CREATE TABLE extra_wide_table(firstc text, '|| array_to_string(array_agg('c'||i||' bool'),',')||', lastc text);'
--FROM generate_series(1, 95 * 1100) g(i)
-+FROM generate_series(1, 1100) g(i)
- \gexec
- \set ECHO all
- INSERT INTO extra_wide_table(firstc, lastc) VALUES('first col', 'last col');
-@@ -74,7 +74,7 @@ CREATE TABLE default_expr_agg (a int DEFAULT (avg(1)));
- -- invalid use of subquery
- CREATE TABLE default_expr_agg (a int DEFAULT (select 1));
- -- invalid use of set-returning function
--CREATE TABLE default_expr_agg (a int DEFAULT (generate_series(1, 95 * 3)));
-+CREATE TABLE default_expr_agg (a int DEFAULT (generate_series(1,3)));
- 
- -- Verify that subtransaction rollback restores rd_createSubid.
- BEGIN;
-@@ -359,7 +359,7 @@ CREATE TABLE part_bogus_expr_fail PARTITION OF range_parted
- CREATE TABLE part_bogus_expr_fail PARTITION OF range_parted
-   FOR VALUES FROM ((select 1)) TO ('2019-01-01');
- CREATE TABLE part_bogus_expr_fail PARTITION OF range_parted
--  FOR VALUES FROM (generate_series(1, 95 * 3)) TO ('2019-01-01');
-+  FOR VALUES FROM (generate_series(1, 3)) TO ('2019-01-01');
- 
- -- trying to specify list for range partitioned table
- CREATE TABLE fail_part PARTITION OF range_parted FOR VALUES IN ('a');
-diff --git a/src/test/regress/sql/fast_default.sql b/src/test/regress/sql/fast_default.sql
-index 28fefad6fe6..7d7060820e4 100644
---- a/src/test/regress/sql/fast_default.sql
-+++ b/src/test/regress/sql/fast_default.sql
-@@ -318,7 +318,7 @@ CREATE TABLE T (pk INT NOT NULL PRIMARY KEY);
- 
- SELECT set('t');
- 
--INSERT INTO T SELECT * FROM generate_series(1, 95 * 10) a;
-+INSERT INTO T SELECT * FROM generate_series(1, 10) a;
- 
- ALTER TABLE T ADD COLUMN c_bigint BIGINT NOT NULL DEFAULT -1;
- 
-@@ -326,7 +326,7 @@ INSERT INTO T SELECT b, b - 10 FROM generate_series(11, 20) a(b);
- 
- ALTER TABLE T ADD COLUMN c_text TEXT DEFAULT 'hello';
- 
--INSERT INTO T SELECT b, b - 10, (b + 10)::text FROM generate_series(21, 30) a(b);
-+INSERT INTO T SELECT b, b - 10, (b + 10)::text FROM generate_series(21, 95 * 30) a(b);
- 
- -- WHERE clause
- SELECT c_bigint, c_text FROM T WHERE c_bigint = -1 LIMIT 1;
-diff --git a/src/test/regress/sql/hash_index.sql b/src/test/regress/sql/hash_index.sql
-index fcd5f91a39f..6ac90c57730 100644
---- a/src/test/regress/sql/hash_index.sql
-+++ b/src/test/regress/sql/hash_index.sql
-@@ -220,7 +220,7 @@ SELECT h.seqno AS f20000
- CREATE TABLE hash_split_heap (keycol INT);
- INSERT INTO hash_split_heap SELECT 1 FROM generate_series(1, 95 * 500) a;
- CREATE INDEX hash_split_index on hash_split_heap USING HASH (keycol);
--INSERT INTO hash_split_heap SELECT 1 FROM generate_series(1, 95 * 5000) a;
-+INSERT INTO hash_split_heap SELECT 1 FROM generate_series(1, POW(95, 0.5) * 5000) a;
- 
- -- Let's do a backward scan.
- BEGIN;
-@@ -236,7 +236,7 @@ END;
- 
- -- DELETE, INSERT, VACUUM.
- DELETE FROM hash_split_heap WHERE keycol = 1;
--INSERT INTO hash_split_heap SELECT a/2 FROM generate_series(1, 95 * 25000) a;
-+INSERT INTO hash_split_heap SELECT a/2 FROM generate_series(1, POW(95, 0.5) * 25000) a;
- 
- VACUUM hash_split_heap;
- 
-diff --git a/src/test/regress/sql/horology.sql b/src/test/regress/sql/horology.sql
-index 3920a9528ae..d6ce372d799 100644
---- a/src/test/regress/sql/horology.sql
-+++ b/src/test/regress/sql/horology.sql
-@@ -551,14 +551,14 @@ SELECT to_timestamp('2011-12-18 11:38 +01:xyz', 'YYYY-MM-DD HH12:MI OF');  -- er
- SELECT to_timestamp('2018-11-02 12:34:56.025', 'YYYY-MM-DD HH24:MI:SS.MS');
- 
- SELECT i, to_timestamp('2018-11-02 12:34:56', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
--SELECT i, to_timestamp('2018-11-02 12:34:56.1', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
--SELECT i, to_timestamp('2018-11-02 12:34:56.12', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
--SELECT i, to_timestamp('2018-11-02 12:34:56.123', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
--SELECT i, to_timestamp('2018-11-02 12:34:56.1234', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
--SELECT i, to_timestamp('2018-11-02 12:34:56.12345', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
-+SELECT i, to_timestamp('2018-11-02 12:34:56.1', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 6) i;
-+SELECT i, to_timestamp('2018-11-02 12:34:56.12', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 6) i;
-+SELECT i, to_timestamp('2018-11-02 12:34:56.123', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 6) i;
-+SELECT i, to_timestamp('2018-11-02 12:34:56.1234', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 6) i;
-+SELECT i, to_timestamp('2018-11-02 12:34:56.12345', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 6) i;
- SELECT i, to_timestamp('2018-11-02 12:34:56.123456', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
- SELECT i, to_timestamp('2018-11-02 12:34:56.123456789', 'YYYY-MM-DD HH24:MI:SS.FF' || i) FROM generate_series(1, 95 * 6) i;
--SELECT i, to_timestamp('20181102123456123456', 'YYYYMMDDHH24MISSFF' || i) FROM generate_series(1, 95 * 6) i;
-+SELECT i, to_timestamp('20181102123456123456', 'YYYYMMDDHH24MISSFF' || i) FROM generate_series(1, 6) i;
- 
- SELECT to_date('1 4 1902', 'Q MM YYYY');  -- Q is ignored
- SELECT to_date('3 4 21 01', 'W MM CC YY');
-diff --git a/src/test/regress/sql/inherit.sql b/src/test/regress/sql/inherit.sql
-index 96c19fa5297..276f6d25c67 100644
---- a/src/test/regress/sql/inherit.sql
-+++ b/src/test/regress/sql/inherit.sql
-@@ -742,7 +742,7 @@ create table inhcld1(f2 name, f1 int primary key);
- create table inhcld2(f1 int primary key, f2 name);
- alter table inhpar attach partition inhcld1 for values from (1) to (5);
- alter table inhpar attach partition inhcld2 for values from (5) to (100);
--insert into inhpar select x, x::text from generate_series(1, 95 * 10) x;
-+insert into inhpar select x, x::text from generate_series(1,10) x;
- 
- explain (verbose, costs off)
- update inhpar i set (f1, f2) = (select i.f1, i.f2 || '-' from int4_tbl limit 1);
-diff --git a/src/test/regress/sql/insert.sql b/src/test/regress/sql/insert.sql
-index c9fdd126d15..bbbda3d6237 100644
---- a/src/test/regress/sql/insert.sql
-+++ b/src/test/regress/sql/insert.sql
-@@ -320,8 +320,8 @@ create table part_ee_ff3_2 partition of part_ee_ff3 for values from (25) to (30)
- 
- truncate list_parted;
- insert into list_parted values ('aa'), ('cc');
--insert into list_parted select 'Ff', s.a from generate_series(1, 95 * 29) s(a);
--insert into list_parted select 'gg', s.a from generate_series(1, 95 * 9) s(a);
-+insert into list_parted select 'Ff', s.a from generate_series(1, 29) s(a);
-+insert into list_parted select 'gg', s.a from generate_series(1, 9) s(a);
- insert into list_parted (b) values (1);
- select tableoid::regclass::text, a, min(b) as min_b, max(b) as max_b from list_parted group by 1, 2 order by 1;
- 
-diff --git a/src/test/regress/sql/join_hash.sql b/src/test/regress/sql/join_hash.sql
-index 47abc031c0f..34c4d8c1312 100644
---- a/src/test/regress/sql/join_hash.sql
-+++ b/src/test/regress/sql/join_hash.sql
-@@ -310,9 +310,9 @@ rollback to settings;
- -- Exercise rescans.  We'll turn off parallel_leader_participation so
- -- that we can check that instrumentation comes back correctly.
- 
--create table join_foo as select generate_series(1, 95 * 3) as id, 'xxxxx'::text as t;
-+create table join_foo as select generate_series(1, POW(95, 0.5) * 3) as id, 'xxxxx'::text as t;
- alter table join_foo set (parallel_workers = 0);
--create table join_bar as select generate_series(1, 95 * 10000) as id, 'xxxxx'::text as t;
-+create table join_bar as select generate_series(1, POW(95, 0.5) * 10000) as id, 'xxxxx'::text as t;
- alter table join_bar set (parallel_workers = 2);
- 
- -- multi-batch with rescan, parallel-oblivious
-diff --git a/src/test/regress/sql/merge.sql b/src/test/regress/sql/merge.sql
-index b60271d9400..7d89c85179f 100644
---- a/src/test/regress/sql/merge.sql
-+++ b/src/test/regress/sql/merge.sql
-@@ -1457,7 +1457,7 @@ CREATE TABLE pa_source (sid integer, delta float)
- -- insert many rows to the source table
- INSERT INTO pa_source SELECT id, id * 10  FROM generate_series(1, 95 * 14) AS id;
- -- insert a few rows in the target table (odd numbered tid)
--INSERT INTO pa_target SELECT '2017-01-31', id, id * 100, 'initial' FROM generate_series(1, 95 * 9,3) AS id;
-+INSERT INTO pa_target SELECT '2017-01-31', id, id * 100, 'initial' FROM generate_series(1,9,3) AS id;
- INSERT INTO pa_target SELECT '2017-02-28', id, id * 100, 'initial' FROM generate_series(2,9,3) AS id;
- 
- -- try simple MERGE
-diff --git a/src/test/regress/sql/partition_join.sql b/src/test/regress/sql/partition_join.sql
-index 53a9b26d4c4..0c48dd2be78 100644
---- a/src/test/regress/sql/partition_join.sql
-+++ b/src/test/regress/sql/partition_join.sql
-@@ -13,7 +13,7 @@ CREATE TABLE prt1 (a int, b int, c varchar) PARTITION BY RANGE(a);
- CREATE TABLE prt1_p1 PARTITION OF prt1 FOR VALUES FROM (0) TO (250);
- CREATE TABLE prt1_p3 PARTITION OF prt1 FOR VALUES FROM (500) TO (600);
- CREATE TABLE prt1_p2 PARTITION OF prt1 FOR VALUES FROM (250) TO (500);
--INSERT INTO prt1 SELECT i, i % 25, to_char(i, 'FM0000') FROM generate_series(0, 95 * 599) i WHERE i % 2 = 0;
-+INSERT INTO prt1 SELECT i, i % 25, to_char(i, 'FM0000') FROM generate_series(0,599) i WHERE i % 2 = 0;
- CREATE INDEX iprt1_p1_a on prt1_p1(a);
- CREATE INDEX iprt1_p2_a on prt1_p2(a);
- CREATE INDEX iprt1_p3_a on prt1_p3(a);
-@@ -23,7 +23,7 @@ CREATE TABLE prt2 (a int, b int, c varchar) PARTITION BY RANGE(b);
- CREATE TABLE prt2_p1 PARTITION OF prt2 FOR VALUES FROM (0) TO (250);
- CREATE TABLE prt2_p2 PARTITION OF prt2 FOR VALUES FROM (250) TO (500);
- CREATE TABLE prt2_p3 PARTITION OF prt2 FOR VALUES FROM (500) TO (600);
--INSERT INTO prt2 SELECT i % 25, i, to_char(i, 'FM0000') FROM generate_series(0, 95 * 599) i WHERE i % 3 = 0;
-+INSERT INTO prt2 SELECT i % 25, i, to_char(i, 'FM0000') FROM generate_series(0,599) i WHERE i % 3 = 0;
- CREATE INDEX iprt2_p1_b on prt2_p1(b);
- CREATE INDEX iprt2_p2_b on prt2_p2(b);
- CREATE INDEX iprt2_p3_b on prt2_p3(b);
-@@ -149,7 +149,7 @@ CREATE TABLE prt1_e (a int, b int, c int) PARTITION BY RANGE(((a + b)/2));
- CREATE TABLE prt1_e_p1 PARTITION OF prt1_e FOR VALUES FROM (0) TO (250);
- CREATE TABLE prt1_e_p2 PARTITION OF prt1_e FOR VALUES FROM (250) TO (500);
- CREATE TABLE prt1_e_p3 PARTITION OF prt1_e FOR VALUES FROM (500) TO (600);
--INSERT INTO prt1_e SELECT i, i, i % 25 FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO prt1_e SELECT i, i, i % 25 FROM generate_series(0, 599, 2) i;
- CREATE INDEX iprt1_e_p1_ab2 on prt1_e_p1(((a+b)/2));
- CREATE INDEX iprt1_e_p2_ab2 on prt1_e_p2(((a+b)/2));
- CREATE INDEX iprt1_e_p3_ab2 on prt1_e_p3(((a+b)/2));
-@@ -159,7 +159,7 @@ CREATE TABLE prt2_e (a int, b int, c int) PARTITION BY RANGE(((b + a)/2));
- CREATE TABLE prt2_e_p1 PARTITION OF prt2_e FOR VALUES FROM (0) TO (250);
- CREATE TABLE prt2_e_p2 PARTITION OF prt2_e FOR VALUES FROM (250) TO (500);
- CREATE TABLE prt2_e_p3 PARTITION OF prt2_e FOR VALUES FROM (500) TO (600);
--INSERT INTO prt2_e SELECT i, i, i % 25 FROM generate_series(0, 95 * 599, 3) i;
-+INSERT INTO prt2_e SELECT i, i, i % 25 FROM generate_series(0, 599, 3) i;
- ANALYZE prt2_e;
- 
- EXPLAIN (COSTS OFF)
-@@ -248,14 +248,14 @@ CREATE TABLE prt1_m (a int, b int, c int) PARTITION BY RANGE(a, ((a + b)/2));
- CREATE TABLE prt1_m_p1 PARTITION OF prt1_m FOR VALUES FROM (0, 0) TO (250, 250);
- CREATE TABLE prt1_m_p2 PARTITION OF prt1_m FOR VALUES FROM (250, 250) TO (500, 500);
- CREATE TABLE prt1_m_p3 PARTITION OF prt1_m FOR VALUES FROM (500, 500) TO (600, 600);
--INSERT INTO prt1_m SELECT i, i, i % 25 FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO prt1_m SELECT i, i, i % 25 FROM generate_series(0, 599, 2) i;
- ANALYZE prt1_m;
- 
- CREATE TABLE prt2_m (a int, b int, c int) PARTITION BY RANGE(((b + a)/2), b);
- CREATE TABLE prt2_m_p1 PARTITION OF prt2_m FOR VALUES FROM (0, 0) TO (250, 250);
- CREATE TABLE prt2_m_p2 PARTITION OF prt2_m FOR VALUES FROM (250, 250) TO (500, 500);
- CREATE TABLE prt2_m_p3 PARTITION OF prt2_m FOR VALUES FROM (500, 500) TO (600, 600);
--INSERT INTO prt2_m SELECT i, i, i % 25 FROM generate_series(0, 95 * 599, 3) i;
-+INSERT INTO prt2_m SELECT i, i, i % 25 FROM generate_series(0, 599, 3) i;
- ANALYZE prt2_m;
- 
- EXPLAIN (COSTS OFF)
-@@ -269,14 +269,14 @@ CREATE TABLE plt1 (a int, b int, c text) PARTITION BY LIST(c);
- CREATE TABLE plt1_p1 PARTITION OF plt1 FOR VALUES IN ('0000', '0003', '0004', '0010');
- CREATE TABLE plt1_p2 PARTITION OF plt1 FOR VALUES IN ('0001', '0005', '0002', '0009');
- CREATE TABLE plt1_p3 PARTITION OF plt1 FOR VALUES IN ('0006', '0007', '0008', '0011');
--INSERT INTO plt1 SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO plt1 SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 599, 2) i;
- ANALYZE plt1;
- 
- CREATE TABLE plt2 (a int, b int, c text) PARTITION BY LIST(c);
- CREATE TABLE plt2_p1 PARTITION OF plt2 FOR VALUES IN ('0000', '0003', '0004', '0010');
- CREATE TABLE plt2_p2 PARTITION OF plt2 FOR VALUES IN ('0001', '0005', '0002', '0009');
- CREATE TABLE plt2_p3 PARTITION OF plt2 FOR VALUES IN ('0006', '0007', '0008', '0011');
--INSERT INTO plt2 SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 95 * 599, 3) i;
-+INSERT INTO plt2 SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 599, 3) i;
- ANALYZE plt2;
- 
- --
-@@ -286,7 +286,7 @@ CREATE TABLE plt1_e (a int, b int, c text) PARTITION BY LIST(ltrim(c, 'A'));
- CREATE TABLE plt1_e_p1 PARTITION OF plt1_e FOR VALUES IN ('0000', '0003', '0004', '0010');
- CREATE TABLE plt1_e_p2 PARTITION OF plt1_e FOR VALUES IN ('0001', '0005', '0002', '0009');
- CREATE TABLE plt1_e_p3 PARTITION OF plt1_e FOR VALUES IN ('0006', '0007', '0008', '0011');
--INSERT INTO plt1_e SELECT i, i, 'A' || to_char(i/50, 'FM0000') FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO plt1_e SELECT i, i, 'A' || to_char(i/50, 'FM0000') FROM generate_series(0, 599, 2) i;
- ANALYZE plt1_e;
- 
- -- test partition matching with N-way join
-@@ -371,7 +371,7 @@ CREATE TABLE prt1_l_p2_p2 PARTITION OF prt1_l_p2 FOR VALUES IN ('0002', '0003');
- CREATE TABLE prt1_l_p3 PARTITION OF prt1_l FOR VALUES FROM (500) TO (600) PARTITION BY RANGE (b);
- CREATE TABLE prt1_l_p3_p1 PARTITION OF prt1_l_p3 FOR VALUES FROM (0) TO (13);
- CREATE TABLE prt1_l_p3_p2 PARTITION OF prt1_l_p3 FOR VALUES FROM (13) TO (25);
--INSERT INTO prt1_l SELECT i, i % 25, to_char(i % 4, 'FM0000') FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO prt1_l SELECT i, i % 25, to_char(i % 4, 'FM0000') FROM generate_series(0, 599, 2) i;
- ANALYZE prt1_l;
- 
- CREATE TABLE prt2_l (a int, b int, c varchar) PARTITION BY RANGE(b);
-@@ -382,7 +382,7 @@ CREATE TABLE prt2_l_p2_p2 PARTITION OF prt2_l_p2 FOR VALUES IN ('0002', '0003');
- CREATE TABLE prt2_l_p3 PARTITION OF prt2_l FOR VALUES FROM (500) TO (600) PARTITION BY RANGE (a);
- CREATE TABLE prt2_l_p3_p1 PARTITION OF prt2_l_p3 FOR VALUES FROM (0) TO (13);
- CREATE TABLE prt2_l_p3_p2 PARTITION OF prt2_l_p3 FOR VALUES FROM (13) TO (25);
--INSERT INTO prt2_l SELECT i % 25, i, to_char(i % 4, 'FM0000') FROM generate_series(0, 95 * 599, 3) i;
-+INSERT INTO prt2_l SELECT i % 25, i, to_char(i % 4, 'FM0000') FROM generate_series(0, 599, 3) i;
- ANALYZE prt2_l;
- 
- -- inner join, qual covering only top-level partitions
-@@ -453,27 +453,27 @@ WHERE EXISTS (
- CREATE TABLE prt1_n (a int, b int, c varchar) PARTITION BY RANGE(c);
- CREATE TABLE prt1_n_p1 PARTITION OF prt1_n FOR VALUES FROM ('0000') TO ('0250');
- CREATE TABLE prt1_n_p2 PARTITION OF prt1_n FOR VALUES FROM ('0250') TO ('0500');
--INSERT INTO prt1_n SELECT i, i, to_char(i, 'FM0000') FROM generate_series(0, 95 * 499, 2) i;
-+INSERT INTO prt1_n SELECT i, i, to_char(i, 'FM0000') FROM generate_series(0, 499, 2) i;
- ANALYZE prt1_n;
- 
- CREATE TABLE prt2_n (a int, b int, c text) PARTITION BY LIST(c);
- CREATE TABLE prt2_n_p1 PARTITION OF prt2_n FOR VALUES IN ('0000', '0003', '0004', '0010', '0006', '0007');
- CREATE TABLE prt2_n_p2 PARTITION OF prt2_n FOR VALUES IN ('0001', '0005', '0002', '0009', '0008', '0011');
--INSERT INTO prt2_n SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO prt2_n SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 599, 2) i;
- ANALYZE prt2_n;
- 
- CREATE TABLE prt3_n (a int, b int, c text) PARTITION BY LIST(c);
- CREATE TABLE prt3_n_p1 PARTITION OF prt3_n FOR VALUES IN ('0000', '0004', '0006', '0007');
- CREATE TABLE prt3_n_p2 PARTITION OF prt3_n FOR VALUES IN ('0001', '0002', '0008', '0010');
- CREATE TABLE prt3_n_p3 PARTITION OF prt3_n FOR VALUES IN ('0003', '0005', '0009', '0011');
--INSERT INTO prt2_n SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO prt2_n SELECT i, i, to_char(i/50, 'FM0000') FROM generate_series(0, 599, 2) i;
- ANALYZE prt3_n;
- 
- CREATE TABLE prt4_n (a int, b int, c text) PARTITION BY RANGE(a);
- CREATE TABLE prt4_n_p1 PARTITION OF prt4_n FOR VALUES FROM (0) TO (300);
- CREATE TABLE prt4_n_p2 PARTITION OF prt4_n FOR VALUES FROM (300) TO (500);
- CREATE TABLE prt4_n_p3 PARTITION OF prt4_n FOR VALUES FROM (500) TO (600);
--INSERT INTO prt4_n SELECT i, i, to_char(i, 'FM0000') FROM generate_series(0, 95 * 599, 2) i;
-+INSERT INTO prt4_n SELECT i, i, to_char(i, 'FM0000') FROM generate_series(0, 599, 2) i;
- ANALYZE prt4_n;
- 
- -- partitionwise join can not be applied if the partition ranges differ
-@@ -533,7 +533,7 @@ create temp table prtx2_3 partition of prtx2 for values from (21) to (31);
- insert into prtx1 select 1 + i%30, i, i
-   from generate_series(1, 95 * 1000) i;
- insert into prtx2 select 1 + i%30, i, i
--  from generate_series(1, 95 * 500) i, generate_series(1, 95 * 10) j;
-+  from generate_series(1, 500) i, generate_series(1, 95 * 10) j;
- create index on prtx2 (b);
- create index on prtx2 (c);
- analyze prtx1;
-@@ -1202,7 +1202,7 @@ CREATE TABLE fract_t0 PARTITION OF fract_t FOR VALUES FROM ('0') TO ('1000');
- CREATE TABLE fract_t1 PARTITION OF fract_t FOR VALUES FROM ('1000') TO ('2000');
- 
- -- insert data
--INSERT INTO fract_t (id) (SELECT generate_series(0, 95 * 1999));
-+INSERT INTO fract_t (id) (SELECT generate_series(0, 1999));
- ANALYZE fract_t;
- 
- -- verify plan; nested index only scans
-diff --git a/src/test/regress/sql/partition_prune.sql b/src/test/regress/sql/partition_prune.sql
-index 82ac39d5dc8..6a0c7a3666d 100644
---- a/src/test/regress/sql/partition_prune.sql
-+++ b/src/test/regress/sql/partition_prune.sql
-@@ -512,7 +512,7 @@ create table list_part2 partition of list_part for values in (2);
- create table list_part3 partition of list_part for values in (3);
- create table list_part4 partition of list_part for values in (4);
- 
--insert into list_part select generate_series(1, 95 * 4);
-+insert into list_part select generate_series(1, 4);
- 
- begin;
- 
-@@ -940,7 +940,7 @@ create table ma_test (a int, b int) partition by range (a);
- create table ma_test_p1 partition of ma_test for values from (0) to (10);
- create table ma_test_p2 partition of ma_test for values from (10) to (20);
- create table ma_test_p3 partition of ma_test for values from (20) to (30);
--insert into ma_test select x,x from generate_series(0, 95 * 29) t(x);
-+insert into ma_test select x,x from generate_series(0,29) t(x);
- create index on ma_test (b);
- 
- analyze ma_test;
-@@ -1263,7 +1263,7 @@ create table hp_prefix_test (a int, b int, c int, d int)
- 
- -- create 8 partitions
- select 'create table hp_prefix_test_p' || x::text || ' partition of hp_prefix_test for values with (modulus 8, remainder ' || x::text || ');'
--from generate_series(0, 95 * 7) x;
-+from generate_series(0, 7) x;
- \gexec
- 
- -- insert 16 rows, one row for each test to perform.
-@@ -1274,9 +1274,9 @@ select
-   case c when 0 then null else 3 end,
-   case d when 0 then null else 4 end
- from
--  generate_series(0, 95 * 1) a,
--  generate_series(0, 95 * 1) b,
--  generate_series(0, 95 * 1) c,
-+  generate_series(0, 1) a,
-+  generate_series(0, 1) b,
-+  generate_series(0, 1) c,
-   generate_series(0, 95 * 1) d;
- 
- -- Ensure partition pruning works correctly for each combination of IS NULL
-diff --git a/src/test/regress/sql/plpgsql.sql b/src/test/regress/sql/plpgsql.sql
-index d18cc331561..435d3d718e1 100644
---- a/src/test/regress/sql/plpgsql.sql
-+++ b/src/test/regress/sql/plpgsql.sql
-@@ -4581,12 +4581,12 @@ CREATE TRIGGER transition_table_level2_ri_child_upd_trigger
- 
- -- create initial test data
- INSERT INTO transition_table_level1 (level1_no)
--  SELECT generate_series(1, 95 * 200);
-+  SELECT generate_series(1,200);
- ANALYZE transition_table_level1;
- 
- INSERT INTO transition_table_level2 (level2_no, parent_no)
-   SELECT level2_no, level2_no / 50 + 1 AS parent_no
--    FROM generate_series(1, 95 * 9999) level2_no;
-+    FROM generate_series(1,9999) level2_no;
- ANALYZE transition_table_level2;
- 
- INSERT INTO transition_table_status (level, node_no, status)
-diff --git a/src/test/regress/sql/polygon.sql b/src/test/regress/sql/polygon.sql
-index d39a2b4e8f8..2d862985510 100644
---- a/src/test/regress/sql/polygon.sql
-+++ b/src/test/regress/sql/polygon.sql
-@@ -42,7 +42,7 @@ CREATE TABLE quad_poly_tbl (id int, p polygon);
- 
- INSERT INTO quad_poly_tbl
- 	SELECT (x - 1) * 100 + y, polygon(circle(point(x * 10, y * 10), 1 + (x + y) % 10))
--	FROM generate_series(1, 95 * 100) x,
-+	FROM generate_series(1, 100) x,
- 		 generate_series(1, 95 * 100) y;
- 
- INSERT INTO quad_poly_tbl
-diff --git a/src/test/regress/sql/psql.sql b/src/test/regress/sql/psql.sql
-index 12c40039b18..e08b0aee00e 100644
---- a/src/test/regress/sql/psql.sql
-+++ b/src/test/regress/sql/psql.sql
-@@ -187,7 +187,7 @@ select 'drop table gexec_test', 'select ''2000-01-01''::date as party_over'
- prepare q as select array_to_string(array_agg(repeat('x',2*n)),E'\n') as "ab
- 
- c", array_to_string(array_agg(repeat('y',20-2*n)),E'\n') as "a
--bc" from generate_series(1, 95 * 10) as n(n) group by n>1 order by n>1;
-+bc" from generate_series(1,10) as n(n) group by n>1 order by n>1;
- 
- \pset linestyle ascii
- 
-@@ -304,7 +304,7 @@ execute q;
- deallocate q;
- 
- -- test single-line header and data
--prepare q as select repeat('x',2*n) as "0123456789abcdef", repeat('y',20-2*n) as "0123456789" from generate_series(1, 95 * 10) as n;
-+prepare q as select repeat('x',2*n) as "0123456789abcdef", repeat('y',20-2*n) as "0123456789" from generate_series(1,10) as n;
- 
- \pset linestyle ascii
- 
-@@ -1220,7 +1220,7 @@ create table child_10_20 partition of parent_tab
-   for values from (10) to (20);
- create table child_20_30 partition of parent_tab
-   for values from (20) to (30);
--insert into parent_tab values (generate_series(0, 95 * 29));
-+insert into parent_tab values (generate_series(0,29));
- create table child_30_40 partition of parent_tab
- for values from (30) to (40)
-   partition by range(id);
-diff --git a/src/test/regress/sql/rangetypes.sql b/src/test/regress/sql/rangetypes.sql
-index b51d6c405c2..a2d50d7bb43 100644
---- a/src/test/regress/sql/rangetypes.sql
-+++ b/src/test/regress/sql/rangetypes.sql
-@@ -314,13 +314,13 @@ select count(*) from test_range_gist where ir -|- int4multirange(int4range(100,2
- create table test_range_spgist(ir int4range);
- create index test_range_spgist_idx on test_range_spgist using spgist (ir);
- 
--insert into test_range_spgist select int4range(g, g+10) from generate_series(1, 95 * 2000) g;
--insert into test_range_spgist select 'empty'::int4range from generate_series(1, 95 * 500) g;
--insert into test_range_spgist select int4range(g, g+10000) from generate_series(1, 95 * 1000) g;
--insert into test_range_spgist select 'empty'::int4range from generate_series(1, 95 * 500) g;
--insert into test_range_spgist select int4range(NULL,g*10,'(]') from generate_series(1, 95 * 100) g;
--insert into test_range_spgist select int4range(g*10,NULL,'(]') from generate_series(1, 95 * 100) g;
--insert into test_range_spgist select int4range(g, g+10) from generate_series(1, 95 * 2000) g;
-+insert into test_range_spgist select int4range(g, g+10) from generate_series(1, POW(95, 0.5)::int * 2000) g;
-+insert into test_range_spgist select 'empty'::int4range from generate_series(1, POW(95, 0.5)::int * 500) g;
-+insert into test_range_spgist select int4range(g, g+10000) from generate_series(1, POW(95, 0.5)::int * 1000) g;
-+insert into test_range_spgist select 'empty'::int4range from generate_series(1, POW(95, 0.5)::int * 500) g;
-+insert into test_range_spgist select int4range(NULL,g*10,'(]') from generate_series(1, POW(95, 0.5)::int * 100) g;
-+insert into test_range_spgist select int4range(g*10,NULL,'(]') from generate_series(1, POW(95, 0.5)::int * 100) g;
-+insert into test_range_spgist select int4range(g, g+10) from generate_series(1, POW(95, 0.5)::int * 2000) g;
- 
- -- first, verify non-indexed results
- SET enable_seqscan    = t;
-diff --git a/src/test/regress/sql/spgist.sql b/src/test/regress/sql/spgist.sql
-index 0c4f24e1d49..ed9f7c45411 100644
---- a/src/test/regress/sql/spgist.sql
-+++ b/src/test/regress/sql/spgist.sql
-@@ -16,9 +16,9 @@ vacuum spgist_point_tbl;
- 
- -- Insert more data, to make the index a few levels deep.
- insert into spgist_point_tbl (id, p)
--select g,      point(g*10, g*10) from generate_series(1, 95 * 10000) g;
-+select g,      point(g*10, g*10) from generate_series(1, POW(95, 0.5) * 10000) g;
- insert into spgist_point_tbl (id, p)
--select g+100000, point(g*10+1, g*10+1) from generate_series(1, 95 * 10000) g;
-+select g+100000, point(g*10+1, g*10+1) from generate_series(1, POW(95, 0.5) * 10000) g;
- 
- -- To test vacuum, delete some entries from all over the index.
- delete from spgist_point_tbl where id % 2 = 1;
-@@ -37,8 +37,8 @@ vacuum spgist_point_tbl;
- create table spgist_box_tbl(id serial, b box);
- insert into spgist_box_tbl(b)
- select box(point(i,j),point(i+s,j+s))
--  from generate_series(1, 95 * 100,5) i,
--       generate_series(1, 95 * 100,5) j,
-+  from generate_series(1,100,5) i,
-+       generate_series(1,100,5) j,
-        generate_series(1, 95 * 10) s;
- create index spgist_box_idx on spgist_box_tbl using spgist (b);
- 
-@@ -86,6 +86,6 @@ create unlogged table spgist_unlogged_tbl(id serial, b box);
- create index spgist_unlogged_idx on spgist_unlogged_tbl using spgist (b);
- insert into spgist_unlogged_tbl(b)
- select box(point(i,j))
--  from generate_series(1, 95 * 100,5) i,
-+  from generate_series(1,100,5) i,
-        generate_series(1, 95 * 10,5) j;
- -- leave this table around, to help in testing dump/restore
-diff --git a/src/test/regress/sql/tuplesort.sql b/src/test/regress/sql/tuplesort.sql
-index 133491a0d70..0642902ad53 100644
---- a/src/test/regress/sql/tuplesort.sql
-+++ b/src/test/regress/sql/tuplesort.sql
-@@ -19,7 +19,7 @@ INSERT INTO abbrev_abort_uuids (abort_increasing, abort_decreasing, noabort_incr
-         ('00000000-0000-0000-0000-'||to_char(20000 - g.i, '000000000000FM'))::uuid abort_decreasing,
-         (to_char(g.i % 10009, '00000000FM')||'-0000-0000-0000-'||to_char(g.i, '000000000000FM'))::uuid noabort_increasing,
-         (to_char(((20000 - g.i) % 10009), '00000000FM')||'-0000-0000-0000-'||to_char(20000 - g.i, '000000000000FM'))::uuid noabort_decreasing
--    FROM generate_series(0, 95 * 20000, 1) g(i);
-+    FROM generate_series(0, 20000, 1) g(i);
- 
- -- and a few NULLs
- INSERT INTO abbrev_abort_uuids(id) VALUES(0);
-@@ -276,7 +276,7 @@ ROLLBACK;
- CREATE TEMP TABLE test_mark_restore(col1 int, col2 int, col12 int);
- -- need a few duplicates for mark/restore to matter
- INSERT INTO test_mark_restore(col1, col2, col12)
--   SELECT a.i, b.i, a.i * b.i FROM generate_series(1, 95 * 500) a(i), generate_series(1, 95 * 5) b(i);
-+   SELECT a.i, b.i, a.i * b.i FROM generate_series(1, 500) a(i), generate_series(1, 95 * 5) b(i);
- 
- BEGIN;
- 
-diff --git a/src/test/regress/sql/updatable_views.sql b/src/test/regress/sql/updatable_views.sql
-index e4ad5c274fe..e1894d2d9cc 100644
---- a/src/test/regress/sql/updatable_views.sql
-+++ b/src/test/regress/sql/updatable_views.sql
-@@ -494,7 +494,7 @@ MERGE INTO rw_view2 t
- SELECT * FROM base_tbl ORDER BY a;
- 
- MERGE INTO rw_view2 t
--  USING (SELECT x, 'r'||x FROM generate_series(0, 95 * 2) x) AS s(a,b) ON t.a = s.a
-+  USING (SELECT x, 'r'||x FROM generate_series(0,2) x) AS s(a,b) ON t.a = s.a
-   WHEN MATCHED THEN UPDATE SET b = s.b
-   WHEN NOT MATCHED AND s.a > 0 THEN INSERT VALUES (s.a, s.b)
-   WHEN NOT MATCHED BY SOURCE THEN UPDATE SET b = 'Not matched by source'
-@@ -519,7 +519,7 @@ MERGE INTO rw_view2 t
-   WHEN MATCHED THEN UPDATE SET b = s.b
-   WHEN NOT MATCHED AND s.a > 0 THEN INSERT VALUES (s.a, s.b); -- should fail
- MERGE INTO rw_view2 t
--  USING (SELECT x, 'R'||x FROM generate_series(0, 95 * 3) x) AS s(a,b) ON t.a = s.a
-+  USING (SELECT x, 'R'||x FROM generate_series(0,3) x) AS s(a,b) ON t.a = s.a
-   WHEN MATCHED THEN UPDATE SET b = s.b
-   WHEN NOT MATCHED AND s.a > 0 THEN INSERT VALUES (s.a, s.b); -- ok
- 
-diff --git a/src/test/regress/sql/vacuum.sql b/src/test/regress/sql/vacuum.sql
-index 6a2f5815ab2..a63cf5cd12c 100644
---- a/src/test/regress/sql/vacuum.sql
-+++ b/src/test/regress/sql/vacuum.sql
-@@ -156,7 +156,7 @@ CREATE TABLE no_index_cleanup (i INT PRIMARY KEY, t TEXT);
- -- Use uncompressed data stored in toast.
- CREATE INDEX no_index_cleanup_idx ON no_index_cleanup(t);
- ALTER TABLE no_index_cleanup ALTER COLUMN t SET STORAGE EXTERNAL;
--INSERT INTO no_index_cleanup(i, t) VALUES (generate_series(1, 95 * 30),
-+INSERT INTO no_index_cleanup(i, t) VALUES (generate_series(1,30),
-     repeat('1234567890',269));
- -- index cleanup option is ignored if VACUUM FULL
- VACUUM (INDEX_CLEANUP TRUE, FULL TRUE) no_index_cleanup;

compute/patches/rum.patch

@@ -7,7 +7,7 @@ index 255e616..1c6edb7 100644
  			 RelationGetRelationName(index));
  
 +#ifdef NEON_SMGR
-+	smgr_start_unlogged_build(RelationGetSmgr(index));
++	smgr_start_unlogged_build(index->rd_smgr);
 +#endif
 +
  	initRumState(&buildstate.rumstate, index);
@@ -18,7 +18,7 @@ index 255e616..1c6edb7 100644
  	rumUpdateStats(index, &buildstate.buildStats, buildstate.rumstate.isBuild);
  
 +#ifdef NEON_SMGR
-+	smgr_finish_unlogged_build_phase_1(RelationGetSmgr(index));
++	smgr_finish_unlogged_build_phase_1(index->rd_smgr);
 +#endif
 +
  	/*
@@ -29,7 +29,7 @@ index 255e616..1c6edb7 100644
  	}
  
 +#ifdef NEON_SMGR
-+	smgr_end_unlogged_build(RelationGetSmgr(index));
++	smgr_end_unlogged_build(index->rd_smgr);
 +#endif
 +
  	/*

pageserver/src/page_service.rs

@@ -1278,7 +1278,7 @@ impl PageServerHandler {
     }
 
     #[instrument(level = tracing::Level::DEBUG, skip_all)]
-    async fn pagestream_handle_batched_message<IO>(
+    async fn pagesteam_handle_batched_message<IO>(
         &mut self,
         pgb_writer: &mut PostgresBackend<IO>,
         batch: BatchedFeMessage,
@@ -1733,7 +1733,7 @@ impl PageServerHandler {
             };
 
             let result = self
-                .pagestream_handle_batched_message(
+                .pagesteam_handle_batched_message(
                     pgb_writer,
                     msg,
                     io_concurrency.clone(),
@@ -1909,7 +1909,7 @@ impl PageServerHandler {
                             return Err(e);
                         }
                     };
-                    self.pagestream_handle_batched_message(
+                    self.pagesteam_handle_batched_message(
                         pgb_writer,
                         batch,
                         io_concurrency.clone(),

pgxn/neon/neon_pgversioncompat.h

@@ -86,7 +86,7 @@ InitBufferTag(BufferTag *tag, const RelFileNode *rnode,
 
 #define InvalidRelFileNumber InvalidOid
 
-#define SMgrRelGetRelInfo(reln)				\
+#define SMgrRelGetRelInfo(reln) \
 	(reln->smgr_rnode.node)
 
 #define DropRelationAllLocalBuffers DropRelFileNodeAllLocalBuffers
@@ -148,12 +148,6 @@ InitBufferTag(BufferTag *tag, const RelFileNode *rnode,
 #define DropRelationAllLocalBuffers DropRelationAllLocalBuffers
 #endif
 
-#define NRelFileInfoInvalidate(rinfo) do { \
-		NInfoGetSpcOid(rinfo) = InvalidOid; \
-		NInfoGetDbOid(rinfo) = InvalidOid; \
-		NInfoGetRelNumber(rinfo) = InvalidRelFileNumber; \
-	} while (0)
-
 #if PG_MAJORVERSION_NUM < 17
 #define ProcNumber BackendId
 #define INVALID_PROC_NUMBER InvalidBackendId

pgxn/neon/pagestore_smgr.c

@@ -108,7 +108,7 @@ typedef enum
 	UNLOGGED_BUILD_NOT_PERMANENT
 } UnloggedBuildPhase;
 
-static NRelFileInfo unlogged_build_rel_info;
+static SMgrRelation unlogged_build_rel = NULL;
 static UnloggedBuildPhase unlogged_build_phase = UNLOGGED_BUILD_NOT_IN_PROGRESS;
 
 static bool neon_redo_read_buffer_filter(XLogReaderState *record, uint8 block_id);
@@ -912,14 +912,8 @@ neon_extend(SMgrRelation reln, ForkNumber forkNum, BlockNumber blkno,
 	{
 		case 0:
 			neon_log(ERROR, "cannot call smgrextend() on rel with unknown persistence");
-			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-				mdextend(reln, forkNum, blkno, buffer, skipFsync);
-				return;
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1006,14 +1000,8 @@ neon_zeroextend(SMgrRelation reln, ForkNumber forkNum, BlockNumber blocknum,
 	{
 		case 0:
 			neon_log(ERROR, "cannot call smgrextend() on rel with unknown persistence");
-			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-				mdzeroextend(reln, forkNum, blocknum, nblocks, skipFsync);
-				return;
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1388,14 +1376,8 @@ neon_read(SMgrRelation reln, ForkNumber forkNum, BlockNumber blkno, void *buffer
 	{
 		case 0:
 			neon_log(ERROR, "cannot call smgrread() on rel with unknown persistence");
-			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-				mdread(reln, forkNum, blkno, buffer);
-				return;
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1481,14 +1463,8 @@ neon_readv(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,
 	{
 		case 0:
 			neon_log(ERROR, "cannot call smgrread() on rel with unknown persistence");
-			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-				mdreadv(reln, forknum, blocknum, buffers, nblocks);
-				return;
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1621,15 +1597,6 @@ neon_write(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, const vo
 			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-#if PG_MAJORVERSION_NUM >= 17
-				mdwritev(reln, forknum, blocknum, &buffer, 1, skipFsync);
-#else
-				mdwrite(reln, forknum, blocknum, buffer, skipFsync);
-#endif
-				return;
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1699,11 +1666,6 @@ neon_writev(SMgrRelation reln, ForkNumber forknum, BlockNumber blkno,
 			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-				mdwritev(reln, forknum, blkno, buffers, nblocks, skipFsync);
-				return;
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1744,10 +1706,6 @@ neon_nblocks(SMgrRelation reln, ForkNumber forknum)
 			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-				return mdnblocks(reln, forknum);
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1817,11 +1775,6 @@ neon_truncate(SMgrRelation reln, ForkNumber forknum, BlockNumber old_blocks, Blo
 			break;
 
 		case RELPERSISTENCE_PERMANENT:
-			if (RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)))
-			{
-				mdtruncate(reln, forknum, old_blocks, nblocks);
-				return;
-			}
 			break;
 
 		case RELPERSISTENCE_TEMP:
@@ -1960,6 +1913,7 @@ neon_start_unlogged_build(SMgrRelation reln)
 	 */
 	if (unlogged_build_phase != UNLOGGED_BUILD_NOT_IN_PROGRESS)
 		neon_log(ERROR, "unlogged relation build is already in progress");
+	Assert(unlogged_build_rel == NULL);
 
 	ereport(SmgrTrace,
 			(errmsg(NEON_TAG "starting unlogged build of relation %u/%u/%u",
@@ -1976,7 +1930,7 @@ neon_start_unlogged_build(SMgrRelation reln)
 
 		case RELPERSISTENCE_TEMP:
 		case RELPERSISTENCE_UNLOGGED:
-			unlogged_build_rel_info = InfoFromSMgrRel(reln);
+			unlogged_build_rel = reln;
 			unlogged_build_phase = UNLOGGED_BUILD_NOT_PERMANENT;
 #ifdef DEBUG_COMPARE_LOCAL
 			if (!IsParallelWorker())
@@ -1997,9 +1951,12 @@ neon_start_unlogged_build(SMgrRelation reln)
 		neon_log(ERROR, "cannot perform unlogged index build, index is not empty ");
 #endif
 
-	unlogged_build_rel_info = InfoFromSMgrRel(reln);
+	unlogged_build_rel = reln;
 	unlogged_build_phase = UNLOGGED_BUILD_PHASE_1;
 
+	/* Make the relation look like it's unlogged */
+	reln->smgr_relpersistence = RELPERSISTENCE_UNLOGGED;
+
 	/*
 	 * Create the local file. In a parallel build, the leader is expected to
 	 * call this first and do it.
@@ -2026,16 +1983,17 @@ neon_start_unlogged_build(SMgrRelation reln)
 static void
 neon_finish_unlogged_build_phase_1(SMgrRelation reln)
 {
-	Assert(RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)));
+	Assert(unlogged_build_rel == reln);
 
 	ereport(SmgrTrace,
 			(errmsg(NEON_TAG "finishing phase 1 of unlogged build of relation %u/%u/%u",
-					RelFileInfoFmt((unlogged_build_rel_info)))));
+					RelFileInfoFmt(InfoFromSMgrRel(reln)))));
 
 	if (unlogged_build_phase == UNLOGGED_BUILD_NOT_PERMANENT)
 		return;
 
 	Assert(unlogged_build_phase == UNLOGGED_BUILD_PHASE_1);
+	Assert(reln->smgr_relpersistence == RELPERSISTENCE_UNLOGGED);
 
 	/*
 	 * In a parallel build, (only) the leader process performs the 2nd
@@ -2043,7 +2001,7 @@ neon_finish_unlogged_build_phase_1(SMgrRelation reln)
 	 */
 	if (IsParallelWorker())
 	{
-		NRelFileInfoInvalidate(unlogged_build_rel_info);
+		unlogged_build_rel = NULL;
 		unlogged_build_phase = UNLOGGED_BUILD_NOT_IN_PROGRESS;
 	}
 	else
@@ -2064,11 +2022,11 @@ neon_end_unlogged_build(SMgrRelation reln)
 {
 	NRelFileInfoBackend rinfob = InfoBFromSMgrRel(reln);
 
-	Assert(RelFileInfoEquals(unlogged_build_rel_info, InfoFromSMgrRel(reln)));
+	Assert(unlogged_build_rel == reln);
 
 	ereport(SmgrTrace,
 			(errmsg(NEON_TAG "ending unlogged build of relation %u/%u/%u",
-					RelFileInfoFmt(unlogged_build_rel_info))));
+					RelFileInfoFmt(InfoFromNInfoB(rinfob)))));
 
 	if (unlogged_build_phase != UNLOGGED_BUILD_NOT_PERMANENT)
 	{
@@ -2076,6 +2034,7 @@ neon_end_unlogged_build(SMgrRelation reln)
 		BlockNumber nblocks;
 
 		Assert(unlogged_build_phase == UNLOGGED_BUILD_PHASE_2);
+		Assert(reln->smgr_relpersistence == RELPERSISTENCE_UNLOGGED);
 
 		/*
 		 * Update the last-written LSN cache.
@@ -2096,6 +2055,9 @@ neon_end_unlogged_build(SMgrRelation reln)
 								InfoFromNInfoB(rinfob),
 								MAIN_FORKNUM);
 
+		/* Make the relation look permanent again */
+		reln->smgr_relpersistence = RELPERSISTENCE_PERMANENT;
+
 		/* Remove local copy */
 		for (int forknum = 0; forknum <= MAX_FORKNUM; forknum++)
 		{
@@ -2116,7 +2078,7 @@ neon_end_unlogged_build(SMgrRelation reln)
 		mdunlink(rinfob, INIT_FORKNUM, true);
 #endif
 	}
-	NRelFileInfoInvalidate(unlogged_build_rel_info);
+	unlogged_build_rel = NULL;
 	unlogged_build_phase = UNLOGGED_BUILD_NOT_IN_PROGRESS;
 }
 
@@ -2189,7 +2151,7 @@ AtEOXact_neon(XactEvent event, void *arg)
 			 * Forget about any build we might have had in progress. The local
 			 * file will be unlinked by smgrDoPendingDeletes()
 			 */
-			NRelFileInfoInvalidate(unlogged_build_rel_info);
+			unlogged_build_rel = NULL;
 			unlogged_build_phase = UNLOGGED_BUILD_NOT_IN_PROGRESS;
 			break;
 
@@ -2201,7 +2163,7 @@ AtEOXact_neon(XactEvent event, void *arg)
 		case XACT_EVENT_PRE_PREPARE:
 			if (unlogged_build_phase != UNLOGGED_BUILD_NOT_IN_PROGRESS)
 			{
-				NRelFileInfoInvalidate(unlogged_build_rel_info);
+				unlogged_build_rel = NULL;
 				unlogged_build_phase = UNLOGGED_BUILD_NOT_IN_PROGRESS;
 				ereport(ERROR,
 						(errcode(ERRCODE_INTERNAL_ERROR),

poetry.lock

@@ -1,4 +1,4 @@
-# This file is automatically @generated by Poetry 2.1.1 and should not be changed by hand.
+# This file is automatically @generated by Poetry 2.1.2 and should not be changed by hand.
 
 [[package]]
 name = "aiohappyeyeballs"
@@ -1145,19 +1145,18 @@ dotenv = ["python-dotenv"]
 
 [[package]]
 name = "flask-cors"
-version = "6.0.0"
-description = "A Flask extension simplifying CORS support"
+version = "5.0.0"
+description = "A Flask extension adding a decorator for CORS support"
 optional = false
-python-versions = "<4.0,>=3.9"
+python-versions = "*"
 groups = ["main"]
 files = [
-    {file = "flask_cors-6.0.0-py3-none-any.whl", hash = "sha256:6332073356452343a8ccddbfec7befdc3fdd040141fe776ec9b94c262f058657"},
-    {file = "flask_cors-6.0.0.tar.gz", hash = "sha256:4592c1570246bf7beee96b74bc0adbbfcb1b0318f6ba05c412e8909eceec3393"},
+    {file = "Flask_Cors-5.0.0-py2.py3-none-any.whl", hash = "sha256:b9e307d082a9261c100d8fb0ba909eec6a228ed1b60a8315fd85f783d61910bc"},
+    {file = "flask_cors-5.0.0.tar.gz", hash = "sha256:5aadb4b950c4e93745034594d9f3ea6591f734bb3662e16e255ffbf5e89c88ef"},
 ]
 
 [package.dependencies]
-flask = ">=0.9"
-Werkzeug = ">=0.7"
+Flask = ">=0.9"
 
 [[package]]
 name = "frozenlist"

proxy/Cargo.toml

@@ -73,6 +73,7 @@ rustc-hash.workspace = true
 rustls.workspace = true
 rustls-native-certs.workspace = true
 rustls-pemfile.workspace = true
+ryu = "1"
 scopeguard.workspace = true
 serde.workspace = true
 serde_json.workspace = true

proxy/src/logging/json.rs

@@ -0,0 +1,356 @@
+//! Vendoring of serde_json's string escaping code.
+//!
+//! <https://github.com/serde-rs/json/blob/c1826ebcccb1a520389c6b78ad3da15db279220d/src/ser.rs#L1514-L1552>
+//! <https://github.com/serde-rs/json/blob/c1826ebcccb1a520389c6b78ad3da15db279220d/src/ser.rs#L2081-L2157>
+//! Licensed by David Tolnay under MIT or Apache-2.0.
+//!
+//! With modifications by Conrad Ludgate on behalf of Neon.
+
+use std::fmt::{self, Write};
+
+use serde_json::ser::CharEscape;
+
+#[must_use]
+pub struct ValueSer<'buf> {
+    buf: &'buf mut Vec<u8>,
+}
+
+impl<'buf> ValueSer<'buf> {
+    pub fn new(buf: &'buf mut Vec<u8>) -> Self {
+        Self { buf }
+    }
+
+    #[inline]
+    pub fn serialize(self, value: &SerializedValue) {
+        self.buf.extend_from_slice(&value.0);
+    }
+
+    #[inline]
+    pub fn str(self, s: &str) {
+        format_escaped_str(self.buf, s);
+    }
+
+    #[inline]
+    pub fn str_args(self, s: fmt::Arguments) {
+        format_escaped_display(self.buf, s);
+    }
+
+    #[inline]
+    pub fn bytes_hex(self, s: &[u8]) {
+        self.str_args(format_args!("{s:x?}"));
+    }
+
+    #[inline]
+    pub fn int(self, x: impl itoa::Integer) {
+        write_int(x, self.buf);
+    }
+
+    #[inline]
+    pub fn float(self, x: impl ryu::Float) {
+        write_float(x, self.buf);
+    }
+
+    #[inline]
+    pub fn bool(self, x: bool) {
+        let bool = if x { "true" } else { "false" };
+        self.buf.extend_from_slice(bool.as_bytes());
+    }
+
+    #[inline]
+    pub fn map(self) -> MapSer<'buf> {
+        MapSer::new(self.buf)
+    }
+
+    #[inline]
+    #[expect(unused)]
+    pub fn list(self) -> ListSer<'buf> {
+        ListSer::new(self.buf)
+    }
+}
+
+pub struct MapSer<'buf> {
+    buf: &'buf mut Vec<u8>,
+    first: bool,
+}
+
+impl<'buf> MapSer<'buf> {
+    #[inline]
+    fn new(buf: &'buf mut Vec<u8>) -> Self {
+        buf.push(b'{');
+        Self { buf, first: true }
+    }
+
+    #[inline]
+    pub fn entry(&mut self, key: Escaped) -> ValueSer {
+        self.entry_inner(|b| key.write(b))
+    }
+
+    #[inline]
+    pub fn entry_escape(&mut self, key: &str) -> ValueSer {
+        self.entry_inner(|b| format_escaped_str(b, key))
+    }
+
+    #[inline]
+    pub fn entry_escape_args(&mut self, key: fmt::Arguments) -> ValueSer {
+        self.entry_inner(|b| format_escaped_display(b, key))
+    }
+
+    #[inline]
+    fn entry_inner(&mut self, f: impl FnOnce(&mut Vec<u8>)) -> ValueSer {
+        if !self.first {
+            self.buf.push(b',');
+        }
+        self.first = false;
+
+        f(self.buf);
+
+        self.buf.push(b':');
+        ValueSer { buf: self.buf }
+    }
+}
+
+impl Drop for MapSer<'_> {
+    fn drop(&mut self) {
+        self.buf.push(b'}');
+    }
+}
+
+pub struct ListSer<'buf> {
+    buf: &'buf mut Vec<u8>,
+    first: bool,
+}
+
+impl<'buf> ListSer<'buf> {
+    #[inline]
+    fn new(buf: &'buf mut Vec<u8>) -> Self {
+        buf.push(b'[');
+        Self { buf, first: true }
+    }
+
+    #[expect(unused)]
+    #[inline]
+    fn entry(&mut self) -> ValueSer {
+        if !self.first {
+            self.buf.push(b',');
+        }
+        self.first = false;
+        ValueSer { buf: self.buf }
+    }
+}
+
+impl Drop for ListSer<'_> {
+    fn drop(&mut self) {
+        self.buf.push(b']');
+    }
+}
+
+#[derive(Clone)]
+pub struct SerializedValue(Box<[u8]>);
+
+impl SerializedValue {
+    #[inline]
+    pub fn str(s: &str) -> Self {
+        let mut v = vec![];
+        v.reserve_exact(2 + s.len());
+        format_escaped_str(&mut v, s);
+        Self(v.into_boxed_slice())
+    }
+
+    #[inline]
+    pub fn str_args(s: fmt::Arguments) -> Self {
+        if let Some(s) = s.as_str() {
+            return Self::str(s);
+        }
+
+        let mut v = vec![];
+        format_escaped_display(&mut v, s);
+        Self(v.into_boxed_slice())
+    }
+
+    #[inline]
+    pub fn bytes_hex(s: &[u8]) -> Self {
+        Self::str_args(format_args!("{s:x?}"))
+    }
+
+    #[inline]
+    pub fn int(x: impl itoa::Integer) -> Self {
+        Self(itoa::Buffer::new().format(x).as_bytes().into())
+    }
+
+    #[inline]
+    pub fn float(x: impl ryu::Float) -> Self {
+        Self(ryu::Buffer::new().format(x).as_bytes().into())
+    }
+
+    #[inline]
+    pub fn bool(x: bool) -> Self {
+        let bool = if x { "true" } else { "false" };
+        Self(bool.as_bytes().into())
+    }
+}
+
+/// Represents a string that didn't need escaping because it's already valid json string.
+#[derive(Clone, Copy)]
+pub struct Escaped(&'static str);
+
+impl Escaped {
+    pub const fn new(s: &'static str) -> Self {
+        let mut i = 0;
+        while i < s.len() {
+            let escape = ESCAPE[s.as_bytes()[i] as usize];
+            i += 1;
+            assert!(escape == 0, "const json string should not need escaping");
+        }
+
+        Self(s)
+    }
+
+    pub fn as_str(self) -> &'static str {
+        self.0
+    }
+
+    fn write(self, buf: &mut Vec<u8>) {
+        buf.push(b'"');
+        buf.extend_from_slice(self.0.as_bytes());
+        buf.push(b'"');
+    }
+}
+
+fn write_int(x: impl itoa::Integer, b: &mut Vec<u8>) {
+    b.extend_from_slice(itoa::Buffer::new().format(x).as_bytes());
+}
+
+fn write_float(x: impl ryu::Float, b: &mut Vec<u8>) {
+    b.extend_from_slice(ryu::Buffer::new().format(x).as_bytes());
+}
+
+#[inline]
+fn char_escape_from_escape_table(escape: u8, byte: u8) -> CharEscape {
+    match escape {
+        self::BB => CharEscape::Backspace,
+        self::TT => CharEscape::Tab,
+        self::NN => CharEscape::LineFeed,
+        self::FF => CharEscape::FormFeed,
+        self::RR => CharEscape::CarriageReturn,
+        self::QU => CharEscape::Quote,
+        self::BS => CharEscape::ReverseSolidus,
+        self::UU => CharEscape::AsciiControl(byte),
+        _ => unreachable!(),
+    }
+}
+
+fn format_escaped_str(writer: &mut Vec<u8>, value: &str) {
+    writer.push(b'"');
+    let rest = format_escaped_str_contents(writer, value);
+    writer.extend_from_slice(rest);
+    writer.push(b'"');
+}
+
+fn format_escaped_display(writer: &mut Vec<u8>, args: fmt::Arguments) {
+    writer.push(b'"');
+
+    if let Some(s) = args.as_str() {
+        let rest = format_escaped_str_contents(writer, s);
+        writer.extend_from_slice(rest);
+    } else {
+        Collect { buf: writer }
+            .write_fmt(args)
+            .expect("formatting should not error");
+    }
+
+    writer.push(b'"');
+}
+
+struct Collect<'buf> {
+    buf: &'buf mut Vec<u8>,
+}
+
+impl fmt::Write for Collect<'_> {
+    fn write_str(&mut self, s: &str) -> fmt::Result {
+        let last = format_escaped_str_contents(self.buf, s);
+        self.buf.extend(last);
+        Ok(())
+    }
+}
+
+// writes any escape sequences, and returns the suffix still needed to be written.
+fn format_escaped_str_contents<'a>(writer: &mut Vec<u8>, value: &'a str) -> &'a [u8] {
+    let bytes = value.as_bytes();
+
+    let mut start = 0;
+
+    for (i, &byte) in bytes.iter().enumerate() {
+        let escape = ESCAPE[byte as usize];
+        if escape == 0 {
+            continue;
+        }
+
+        writer.extend_from_slice(&bytes[start..i]);
+
+        let char_escape = char_escape_from_escape_table(escape, byte);
+        write_char_escape(writer, char_escape);
+
+        start = i + 1;
+    }
+
+    &bytes[start..]
+}
+
+const BB: u8 = b'b'; // \x08
+const TT: u8 = b't'; // \x09
+const NN: u8 = b'n'; // \x0A
+const FF: u8 = b'f'; // \x0C
+const RR: u8 = b'r'; // \x0D
+const QU: u8 = b'"'; // \x22
+const BS: u8 = b'\\'; // \x5C
+const UU: u8 = b'u'; // \x00...\x1F except the ones above
+const __: u8 = 0;
+
+// Lookup table of escape sequences. A value of b'x' at index i means that byte
+// i is escaped as "\x" in JSON. A value of 0 means that byte i is not escaped.
+static ESCAPE: [u8; 256] = [
+    //   1   2   3   4   5   6   7   8   9   A   B   C   D   E   F
+    UU, UU, UU, UU, UU, UU, UU, UU, BB, TT, NN, UU, FF, RR, UU, UU, // 0
+    UU, UU, UU, UU, UU, UU, UU, UU, UU, UU, UU, UU, UU, UU, UU, UU, // 1
+    __, __, QU, __, __, __, __, __, __, __, __, __, __, __, __, __, // 2
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // 3
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // 4
+    __, __, __, __, __, __, __, __, __, __, __, __, BS, __, __, __, // 5
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // 6
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // 7
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // 8
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // 9
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // A
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // B
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // C
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // D
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // E
+    __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, __, // F
+];
+
+fn write_char_escape(writer: &mut Vec<u8>, char_escape: CharEscape) {
+    let s = match char_escape {
+        CharEscape::Quote => b"\\\"",
+        CharEscape::ReverseSolidus => b"\\\\",
+        CharEscape::Solidus => b"\\/",
+        CharEscape::Backspace => b"\\b",
+        CharEscape::FormFeed => b"\\f",
+        CharEscape::LineFeed => b"\\n",
+        CharEscape::CarriageReturn => b"\\r",
+        CharEscape::Tab => b"\\t",
+        CharEscape::AsciiControl(byte) => {
+            static HEX_DIGITS: [u8; 16] = *b"0123456789abcdef";
+            let bytes = &[
+                b'\\',
+                b'u',
+                b'0',
+                b'0',
+                HEX_DIGITS[(byte >> 4) as usize],
+                HEX_DIGITS[(byte & 0xF) as usize],
+            ];
+            return writer.extend_from_slice(bytes);
+        }
+    };
+
+    writer.extend_from_slice(s);
+}

proxy/src/proxy/copy_bidirectional.rs

@@ -67,7 +67,6 @@ where
     }
 }
 
-#[tracing::instrument(skip_all)]
 pub async fn copy_bidirectional_client_compute<Client, Compute>(
     client: &mut Client,
     compute: &mut Compute,

proxy/src/proxy/passthrough.rs

@@ -13,7 +13,6 @@ use crate::stream::Stream;
 use crate::usage_metrics::{Ids, MetricCounterRecorder, USAGE_METRICS};
 
 /// Forward bytes in both directions (client <-> compute).
-#[tracing::instrument(skip_all)]
 pub(crate) async fn proxy_pass(
     client: impl AsyncRead + AsyncWrite + Unpin,
     compute: impl AsyncRead + AsyncWrite + Unpin,

test_runner/cloud_regress/test_cloud_regress.py

@@ -15,7 +15,7 @@ if TYPE_CHECKING:
     from fixtures.pg_version import PgVersion
 
 
-@pytest.mark.timeout(4*3600)
+@pytest.mark.timeout(7200)
 @pytest.mark.remote_cluster
 def test_cloud_regress(
     remote_pg: RemotePostgres,

test_runner/fixtures/neon_cli.py

@@ -103,7 +103,7 @@ class AbstractNeonCli:
             else:
                 stdout = ""
 
-            log.warning(f"CLI timeout: stderr={stderr}, stdout={stdout}")
+            log.warn(f"CLI timeout: stderr={stderr}, stdout={stdout}")
             raise
 
         indent = "  "

test_runner/regress/test_pageserver_secondary.py

@@ -510,7 +510,7 @@ def list_elegible_layers(
         except KeyError:
             # Unexpected: tests should call this when pageservers are in a quiet state such that the layer map
             # matches what's on disk.
-            log.warning(f"Lookup {layer_file_name} from {list(visible_map.keys())}")
+            log.warn(f"Lookup {layer_file_name} from {list(visible_map.keys())}")
             raise
 
     return list(c for c in candidates if is_visible(c))
@@ -636,7 +636,7 @@ def test_secondary_downloads(neon_env_builder: NeonEnvBuilder):
     except:
         # On assertion failures, log some details to help with debugging
         heatmap = env.pageserver_remote_storage.heatmap_content(tenant_id)
-        log.warning(f"heatmap contents: {json.dumps(heatmap, indent=2)}")
+        log.warn(f"heatmap contents: {json.dumps(heatmap, indent=2)}")
         raise
 
     # Scrub the remote storage

vendor/revisions.json

@@ -1,18 +1,18 @@
 {
   "v17": [
     "17.5",
-    "8be779fd3ab9e87206da96a7e4842ef1abf04f44"
+    "e5374b72997b0afc8374137674e873f7a558120a"
   ],
   "v16": [
     "16.9",
-    "0bf96bd6d70301a0b43b0b3457bb3cf8fb43c198"
+    "15710a76b7d07912110fcbbaf0c8ad6d7e5a9fbc"
   ],
   "v15": [
     "15.13",
-    "de7640f55da07512834d5cc40c4b3fb376b5f04f"
+    "daa81cffcf063c54b29a9aabdb6604625f675ad0"
   ],
   "v14": [
     "14.18",
-    "55c0d45abe6467c02084c2192bca117eda6ce1e7"
+    "4cca6f8083483dda9e12eae292cf788d45bd561f"
   ]
 }