TEST SCENARIO Purpose: To observe that the patch v14 code is now doing proper cleanups for ALTER PUBLICATION/SUBSCRIPTION. Note: The "!!>>" is extra logging added for testing, not a normal part of PG. Steps: 1. CREATE PUBLICATION for some table T1 2. CREATE SUBSCRIPTION for that publication 3. Pause the tablesync worker in DATASYNC mode (before even created the tablesync slot) 4. Show the slots 5. ALTER PUBLICATION to DROP TABLE T1 6. ALTER SUBSCRIPTION REFRESH PUBLICATION // will discover table T1 is no longer subscribed to. // here is where the AlterSubscription should attempt to do the nececessary slot/origin cleanups 7. Show the slots 8. DROP SUBSCRIPTION // since subscription no longer knows about T1 this would not drop the tablesync slot. // So if step 6 does no T1 slot cleanup then nobody will 9. Show the slots ================== ## ## Normal PUBLICATION of a table ## [postgres@CentOS7-x64 ~]$ psql -d test_pub -c "CREATE PUBLICATION tap_pub FOR TABLE test_tab;" CREATE PUBLICATION ## ## Create subscription, and pause the tablesync in the debugger after it set the DATASYNC ## state but just before it creates the tablesync slot ## [postgres@CentOS7-x64 ~]$ psql -d test_sub -p 54321 -c "DROP SUBSCRIPTION tap_sub;" 2021-01-12 19:01:21.699 AEDT [8059] ERROR: subscription "tap_sub" does not exist 2021-01-12 19:01:21.699 AEDT [8059] STATEMENT: DROP SUBSCRIPTION tap_sub; ERROR: subscription "tap_sub" does not exist [postgres@CentOS7-x64 ~]$ psql -d test_sub -p 54321 -c "CREATE SUBSCRIPTION tap_sub CONNECTION 'host=localhost dbname=test_pub application_name=tap_sub' PUBLICATION tap_pub;" 2021-01-12 19:01:23.264 AEDT [8068] LOG: logical decoding found consistent point at 0/1623108 2021-01-12 19:01:23.264 AEDT [8068] DETAIL: There are no running transactions. 2021-01-12 19:01:23.264 AEDT [8068] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput NOEXPORT_SNAPSHOT NOTICE: created replication slot "tap_sub" on publisher CREATE SUBSCRIPTION 2021-01-12 19:01:23.276 AEDT [8069] LOG: logical replication apply worker for subscription "tap_sub" has started 2021-01-12 19:01:23.276 AEDT [8069] LOG: !!>> The apply worker process has PID = 8069 [postgres@CentOS7-x64 ~]$ 2021-01-12 19:01:23.285 AEDT [8074] LOG: starting logical decoding for slot "tap_sub" 2021-01-12 19:01:23.285 AEDT [8074] DETAIL: Streaming transactions committing after 0/1623140, reading WAL from 0/1623108. 2021-01-12 19:01:23.285 AEDT [8074] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '2', publication_names '"tap_pub"') 2021-01-12 19:01:23.285 AEDT [8074] LOG: logical decoding found consistent point at 0/1623108 2021-01-12 19:01:23.285 AEDT [8074] DETAIL: There are no running transactions. 2021-01-12 19:01:23.285 AEDT [8074] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '2', publication_names '"tap_pub"') 2021-01-12 19:01:23.286 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:23.286 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:23.291 AEDT [8077] LOG: logical replication table synchronization worker for subscription "tap_sub", table "test_tab" has started 2021-01-12 19:01:23.292 AEDT [8077] LOG: !!>> The tablesync worker process has PID = 8077 2021-01-12 19:01:23.292 AEDT [8077] LOG: !!>> Sleeping 30 secs. For debugging, attach to process 8077 now! 2021-01-12 19:01:24.304 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:24.305 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:25.306 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:25.307 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:26.312 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:26.312 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:27.313 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:27.313 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:28.318 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:28.318 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:29.323 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:29.323 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:30.325 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:30.326 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:31.329 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:31.329 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:32.334 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:32.334 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:33.337 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:33.337 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:34.341 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:34.342 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:35.345 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:35.345 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:36.347 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:36.348 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:37.355 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:37.355 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:38.359 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:38.359 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:39.361 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:39.361 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:40.363 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:40.364 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:41.382 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:41.382 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:42.384 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:42.385 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:43.388 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:43.388 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:44.391 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:44.391 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:45.392 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:45.392 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:46.400 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:46.400 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:47.401 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:47.401 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:48.403 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:48.403 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:49.404 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:49.404 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:50.405 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:50.405 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:51.410 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:51.411 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:52.411 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:52.411 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:53.293 AEDT [8077] LOG: !!>> tablesync worker: About to call LogicalRepSyncTableStart to do initial syncing 2021-01-12 19:01:53.412 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:53.412 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:53.414 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:53.414 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:54.432 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:54.432 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:55.434 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:55.434 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:56.435 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:56.435 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:57.437 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:57.437 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:58.438 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:58.438 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:01:59.438 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:01:59.438 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:00.440 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:00.440 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:01.442 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:01.442 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:02.443 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:02.443 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:03.445 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:03.445 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:04.447 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:04.447 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:05.449 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:05.449 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:06.451 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:06.451 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:09.951 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:09.951 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:10.953 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:10.953 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:11.954 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:11.954 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:12.962 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:12.962 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:13.963 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:13.963 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:14.964 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:14.964 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:15.965 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:15.965 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:16.972 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:16.972 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:17.972 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:17.972 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:18.973 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:18.973 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:19.973 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:19.974 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:20.974 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:20.974 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:26.330 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:26.331 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:26.332 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:26.332 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:27.335 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:27.335 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:28.335 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:28.335 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:29.337 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:29.337 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:30.342 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:30.342 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:31.343 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:31.343 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:32.365 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:32.365 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:33.367 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:33.367 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:34.369 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:34.370 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:35.371 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:35.371 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:36.375 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:36.375 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:37.380 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:37.380 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:38.381 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:38.381 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:39.382 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:39.382 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:40.383 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:40.383 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:41.385 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:41.385 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:42.387 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:42.387 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:43.389 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:43.389 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:44.394 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:44.394 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:45.412 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:45.413 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:46.415 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:46.415 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:47.416 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:47.416 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:48.435 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:48.435 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:49.441 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:49.441 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:50.444 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:50.444 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:51.449 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:51.449 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:52.450 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:52.451 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:53.453 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:53.453 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:54.455 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:54.455 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:55.456 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:55.456 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:56.457 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:56.457 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:56.458 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:56.458 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:57.459 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:57.460 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:58.462 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:58.462 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:02:59.466 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:02:59.467 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:00.468 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:00.468 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:01.469 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:01.469 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:02.471 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:02.471 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:03.472 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:03.472 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables ## ## Show the slots - Notive there is no tablesync slot becase we did not get there yet ## psql -d test_pub -c "select * from pg_replication_slots;" slot_name | plugin | slot_type | datoid | database | temporary | active | active_pid | xmin | catalog _xmin | restart_lsn | confirmed_flush_lsn | wal_status | safe_wal_size -----------+----------+-----------+--------+----------+-----------+--------+------------+------+-------- ------+-------------+---------------------+------------+--------------- tap_sub | pgoutput | logical | 16384 | test_pub | f | t | 8074 | | 519 | 0/1623108 | 0/1623140 | reserved | (1 row) [postgres@CentOS7-x64 ~]$ 2021-01-12 19:03:04.487 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:04.487 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:05.488 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:05.488 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:06.489 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:06.489 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:07.492 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:07.492 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:08.493 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:08.494 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:09.496 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:09.496 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:10.503 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:10.503 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:11.510 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:11.510 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:12.513 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:12.513 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:13.514 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:13.514 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:14.516 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:14.516 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:15.518 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:15.518 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:16.519 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:16.519 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:17.521 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:17.521 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:18.529 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:18.529 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:19.531 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:19.531 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:20.533 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:20.533 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:21.540 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:21.540 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:22.546 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:22.546 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:23.546 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:23.546 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:24.548 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:24.548 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:25.552 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:25.553 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:26.554 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:26.554 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:26.555 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:26.555 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:27.557 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:27.557 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:27.817 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:27.817 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:28.819 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:28.819 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:29.819 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:29.820 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:30.826 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:30.826 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:31.828 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:31.828 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables ## ## ALTER PUBLICATION to drop the table previously published ## psql -d test_pub -c "ALTER PUBLICATION tap_pub DROP TABLE test_tab;" 2021-01-12 19:03:32.517 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:32.518 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:33.519 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:33.520 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables ALTER PUBLICATION 2021-01-12 19:03:33.932 AEDT [8074] LOG: !!>> pgoutput_begin_txn 2021-01-12 19:03:33.932 AEDT [8074] CONTEXT: slot "tap_sub", output plugin "pgoutput", in the begin callback, associated LSN 0/1623228 2021-01-12 19:03:33.932 AEDT [8074] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '2', publication_names '"tap_pub"') 2021-01-12 19:03:33.932 AEDT [8074] LOG: !!>> pgoutput_commit_txn 2021-01-12 19:03:33.932 AEDT [8074] CONTEXT: slot "tap_sub", output plugin "pgoutput", in the commit callback, associated LSN 0/1624968 2021-01-12 19:03:33.932 AEDT [8074] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '2', publication_names '"tap_pub"') 2021-01-12 19:03:33.932 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:33.932 AEDT [8069] LOG: !!>> apply worker: apply_dispatch for message kind 'B' 2021-01-12 19:03:33.932 AEDT [8069] LOG: !!>> apply worker: apply_dispatch for message kind 'C' 2021-01-12 19:03:33.932 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:33.932 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables [postgres@CentOS7-x64 ~]$ 2021-01-12 19:03:34.934 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:34.934 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:35.936 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:35.936 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:36.939 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:36.939 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:37.940 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:37.940 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:38.943 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:38.943 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:39.946 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:39.946 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:40.949 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:40.949 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:41.949 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:41.949 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:42.950 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:42.950 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables ## ## ALTER SUBSCRIPTION to REFRESH the publication ## " ## ## Below the AlterSubscription_refresh kills the tablesync worker (PID 8077) ## 2021-01-12 19:03:43.448 AEDT [8123] LOG: !!>> AlterSubscription_refresh: before logicalrep_worker_stop 2021-01-12 19:03:43.448 AEDT [8123] STATEMENT: ALTER SUBSCRIPTION tap_sub REFRESH PUBLICATION; 2021-01-12 19:03:43.952 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:43.952 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:44.955 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:44.955 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:45.957 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:45.957 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:46.963 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:46.964 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:47.965 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:47.965 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:48.970 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:48.970 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:49.977 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:49.977 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:50.979 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:50.979 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:51.982 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:51.982 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:52.882 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:52.882 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:53.883 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:53.883 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:54.885 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:54.885 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:55.899 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:55.899 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:56.551 AEDT [8077] FATAL: terminating logical replication worker due to administrator command 2021-01-12 19:03:56.552 AEDT [7135] LOG: background worker "logical replication worker" (PID 8077) exited with exit code 1 2021-01-12 19:03:56.552 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:56.552 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:56.556 AEDT [8123] LOG: !!>> AlterSubscription_refresh: after logicalrep_worker_stop 2021-01-12 19:03:56.556 AEDT [8123] STATEMENT: ALTER SUBSCRIPTION tap_sub REFRESH PUBLICATION; ## ## Notice the tablesync state is DATASYNC ('d') so there is no tablesync slot yet created (so the subsequent drop slot will fail) ## 2021-01-12 19:03:56.556 AEDT [8123] LOG: !!>> AlterSubscription_refresh: relid 16385 had state d 2021-01-12 19:03:56.556 AEDT [8123] STATEMENT: ALTER SUBSCRIPTION tap_sub REFRESH PUBLICATION; 2021-01-12 19:03:56.556 AEDT [8123] LOG: AlterSubscription_refresh: dropping the tablesync slot "pg_16404_sync_16385". 2021-01-12 19:03:56.556 AEDT [8123] STATEMENT: ALTER SUBSCRIPTION tap_sub REFRESH PUBLICATION; ## ## Notice because the tablesyn slot does not exist the AlterSubscription_refresh give a WARNING about it ## 2021-01-12 19:03:56.556 AEDT [8124] ERROR: replication slot "pg_16404_sync_16385" does not exist 2021-01-12 19:03:56.556 AEDT [8124] STATEMENT: DROP_REPLICATION_SLOT pg_16404_sync_16385 WAIT 2021-01-12 19:03:56.557 AEDT [8123] WARNING: could not drop the replication slot "pg_16404_sync_16385" on publisher 2021-01-12 19:03:56.557 AEDT [8123] DETAIL: The error was: ERROR: replication slot "pg_16404_sync_16385" does not exist 2021-01-12 19:03:56.557 AEDT [8123] LOG: !!>> AlterSubscription_refresh: dropped the tablesync slot "pg_16404_sync_16385". 2021-01-12 19:03:56.557 AEDT [8123] STATEMENT: ALTER SUBSCRIPTION tap_sub REFRESH PUBLICATION; WARNING: could not drop the replication slot "pg_16404_sync_16385" on publisher DETAIL: The error was: ERROR: replication slot "pg_16404_sync_16385" does not exist 2021-01-12 19:03:56.557 AEDT [8123] LOG: table "public.test_tab" removed from subscription "tap_sub" 2021-01-12 19:03:56.557 AEDT [8123] STATEMENT: ALTER SUBSCRIPTION tap_sub REFRESH PUBLICATION; 2021-01-12 19:03:56.562 AEDT [8134] FATAL: terminating logical replication worker due to administrator command 2021-01-12 19:03:56.563 AEDT [7135] LOG: background worker "logical replication worker" (PID 8134) exited with exit code 1 2021-01-12 19:03:56.563 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:56.563 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables ALTER SUBSCRIPTION [postgres@CentOS7-x64 ~]$ 2021-01-12 19:03:57.565 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:57.565 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:58.567 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:58.567 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:03:59.569 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:03:59.569 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:00.570 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:00.570 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:01.580 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:01.580 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:02.582 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:02.582 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:03.595 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:03.595 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:04.597 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:04.597 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:05.601 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:05.601 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:06.602 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:06.602 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:07.625 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:07.626 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:08.636 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:08.636 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:09.638 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:09.638 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:10.643 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:10.643 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:11.645 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:11.645 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:12.647 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:12.647 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:13.648 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:13.648 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:14.649 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:14.649 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables ## ## Drop Subscription to finish the test. ## psql -d test_sub -p 54321 -c "DROP SUBSCRIPTION tap_sub;"2021-01-12 19:04:15.655 AEDT [8069] LOG: !!>> apply worker: LogicalRepApplyLoop 2021-01-12 19:04:15.655 AEDT [8069] LOG: !!>> apply worker: called process_syncing_tables 2021-01-12 19:04:15.779 AEDT [8069] FATAL: terminating logical replication worker due to administrator command 2021-01-12 19:04:15.780 AEDT [7135] LOG: background worker "logical replication worker" (PID 8069) exited with exit code 1 NOTICE: dropped replication slot "tap_sub" on publisher DROP SUBSCRIPTION ## ## Now even the main slot is dropped. ## [postgres@CentOS7-x64 ~]$ psql -d test_pub -c "select * from pg_replication_slots;" slot_name | plugin | slot_type | datoid | database | temporary | active | active_pid | xmin | catalog_x min | restart_lsn | confirmed_flush_lsn | wal_status | safe_wal_size -----------+--------+-----------+--------+----------+-----------+--------+------------+------+---------- ----+-------------+---------------------+------------+--------------- (0 rows) [postgres@CentOS7-x64 ~]$ [END]