v1-0002-Test-the-stats-report-in-parallel-apply-worker.patch
application/octet-stream
Filename: v1-0002-Test-the-stats-report-in-parallel-apply-worker.patch
Type: application/octet-stream
Part: 0
Patch
Same data as JSON:
GET /api/v1/attachments/:id/patch
the parsed metadata as JSON — format, series position, per-file stats; never the diff bytes.
API reference →
Format: format-patch
Series: patch v1-0002
Subject: Test the stats report in parallel apply worker
| File | + | − |
|---|---|---|
| src/test/subscription/t/026_stats.pl | 9 | 0 |
From 0fa996424feeb17032bf44e2c5d5bbb44d65228b Mon Sep 17 00:00:00 2001
From: Zhijie Hou <houzj.fnst@fujitsu.com>
Date: Wed, 15 Apr 2026 16:59:53 +0800
Subject: [PATCH v1 2/2] Test the stats report in parallel apply worker
---
src/test/subscription/t/026_stats.pl | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/src/test/subscription/t/026_stats.pl b/src/test/subscription/t/026_stats.pl
index 5d457060a02..178b3b71e49 100644
--- a/src/test/subscription/t/026_stats.pl
+++ b/src/test/subscription/t/026_stats.pl
@@ -136,6 +136,15 @@ sub create_sub_pub_w_errors
# Truncate test table so that apply worker can continue.
$node_subscriber->safe_psql($db, qq(TRUNCATE $table_name));
+ # Force the publisher to stream the changes to the subscriber immediately so
+ # that the delete_missing conflict can be tested in the parallel apply
+ # worker.
+ $node_publisher->append_conf('postgresql.conf',
+ "debug_logical_replication_streaming = immediate");
+ $node_publisher->reload;
+
+ $node_subscriber->safe_psql($db, qq(ALTER SUBSCRIPTION $sub_name SET (streaming = parallel)));
+
# Delete data from the test table on the publisher. This delete operation
# should be skipped on the subscriber since the table is already empty.
$node_publisher->safe_psql($db, qq(DELETE FROM $table_name;));
--
2.53.0.windows.2