Re: PATCH: logical_work_mem and logical streaming of large in-progress transactions
Tomas Vondra <tomas.vondra@2ndquadrant.com>
Commits
GET /api/v1/messages/:b64id/commits
the thread's linked commits as JSON, with link sources.
API reference →
-
Tighten the concurrent abort check during decoding.
- 2ce353fc1902 14.0 landed
-
Improve hash_create()'s API for some added robustness.
- b3817f5f7746 14.0 landed
-
Use HASH_BLOBS for xidhash.
- a1b8aa1e4eec 14.0 landed
-
Fix initialization of RelationSyncEntry for streaming transactions.
- 69bd60672af6 14.0 landed
-
Remove unused function declaration in logicalproto.h.
- ddd5f6d2609b 14.0 landed
-
Add additional tests to test streaming of in-progress transactions.
- 58b5ae9d62bd 14.0 landed
-
Fix inline marking introduced in commit 464824323e.
- ac15b499f7f9 14.0 landed
-
Add support for streaming to built-in logical replication.
- 464824323e57 14.0 landed
-
Fix the SharedFileSetUnregister API.
- 4ab77697f67a 14.0 landed
-
Fix comment in procarray.c
- 77c7267c37f7 14.0 cited
-
Suppress compiler warning in non-cassert builds.
- e942af7b8261 14.0 cited
-
Extend the BufFile interface.
- 808e13b282ef 14.0 landed
-
Mark a few logical decoding related variables with PGDLLIMPORT.
- b48cac3b10a0 14.0 landed
-
Implement streaming mode in ReorderBuffer.
- 7259736a6e5b 14.0 landed
-
Extend the logical decoding output plugin API with stream methods.
- 45fdc9738b36 14.0 landed
-
WAL Log invalidations at command end with wal_level=logical.
- c55040ccd017 14.0 landed
-
Immediately WAL-log subtransaction and top-level XID association.
- 0bead9af484c 14.0 landed
-
Allow logical replication to transfer data in binary format.
- 9de77b545313 14.0 cited
-
Only superuser can set sslcert/sslkey in postgres_fdw user mappings
- cebf9d6e6ee1 13.0 cited
-
Track statistics for spilling of changes from ReorderBuffer.
- 9290ad198b15 13.0 landed
-
Add logical_decoding_work_mem to limit ReorderBuffer memory usage.
- cec2edfa7859 13.0 landed
-
logical decoding: process ASSIGNMENT during snapshot build
- bac2fae05c77 13.0 cited
-
Emit invalidations to standby for transactions without xid.
- c6ff84b06a68 9.6.0 cited
On 01/31/2018 07:53 AM, Masahiko Sawada wrote: > On Sat, Jan 20, 2018 at 7:08 AM, Tomas Vondra > <tomas.vondra@2ndquadrant.com> wrote: >> On 01/19/2018 03:34 PM, Tomas Vondra wrote: >>> Attached is v5, fixing a silly bug in part 0006, causing segfault when >>> creating a subscription. >>> >> >> Meh, there was a bug in the sgml docs (<variable> vs. <varname>), >> causing another failure. Hopefully v6 will pass the CI build, it does >> pass a build with the same parameters on my system. > > Thank you for working on this. This patch would be helpful for > synchronous replication. > > I haven't looked at the code deeply yet, but I've reviewed the v6 > patch set especially on subscriber side. All of the patches can be > applied to current HEAD cleanly. Here is review comment. > > ---- > CREATE SUBSCRIPTION commands accept work_mem < 64 but it leads ERROR > on publisher side when starting replication. Probably we should check > the value on the subscriber side as well. > > ---- > When streaming = on, if we drop subscription in the middle of > receiving stream changes, DROP SUBSCRIPTION could leak tmp files > (.chages file and .subxacts file). Also it also happens when a > transaction on upstream aborted without abort record. > > ---- > Since we can change both streaming option and work_mem option by ALTER > SUBSCRIPTION, documentation of ALTER SUBSCRIPTION needs to be updated. > > ---- > If we create a subscription without any options, both > pg_subscription.substream and pg_subscription.subworkmem are set to > null. However, since GetSubscription are't aware of NULL we start the > replication with invalid options like follows. > LOG: received replication command: START_REPLICATION SLOT "hoge_sub" > LOGICAL 0/0 (proto_version '2', work_mem '893219954', streaming 'on', > publication_names '"hoge_pub"') > > I think we can set substream to false and subworkmem to -1 instead of > null, and then makes libpqrcv_startstreaming not set streaming option > if stream is -1. > > ---- > Some WARNING messages appeared. Maybe these are for debug purpose? > > WARNING: updating stream stats 0x1c12ef8 4 3 65604 > WARNING: UpdateSpillStats: updating stats 0x1c12ef8 0 0 0 39 41 2632080 > > Regards, > Thanks for the review! I'll address the issues in the next version of the patch. regards -- Tomas Vondra http://www.2ndQuadrant.com PostgreSQL Development, 24x7 Support, Remote DBA, Training & Services