5 cascade setup

application/octet-stream

Filename: 5 cascade setup
Type: application/octet-stream
Part: 0
Message: Re: [HACKERS] logical decoding of two-phase transactions
[ajin@localhost twophasetest]$ ./erik_5_cascade.sh 
-- /home/ajin/install-oss/bin/initdb --pgdata=/home/ajin/twophasetest/mar09/instance1/data --encoding=UTF8                       #  6525
-- /home/ajin/install-oss/bin/initdb --pgdata=/home/ajin/twophasetest/mar09/instance2/data --encoding=UTF8                       #  6526
-- /home/ajin/install-oss/bin/initdb --pgdata=/home/ajin/twophasetest/mar09/instance3/data --encoding=UTF8                       #  6527
-- /home/ajin/install-oss/bin/initdb --pgdata=/home/ajin/twophasetest/mar09/instance4/data --encoding=UTF8                       #  6528
-- /home/ajin/install-oss/bin/initdb --pgdata=/home/ajin/twophasetest/mar09/instance5/data --encoding=UTF8                       #  6529
dropping old tables...
creating tables...
generating data (client-side)...
100000 of 100000 tuples (100%) done (elapsed 0.19 s, remaining 0.00 s)
vacuuming...
creating primary keys...
done in 0.63 s (drop tables 0.00 s, create tables 0.01 s, client-side generate 0.30 s, vacuum 0.18 s, primary keys 0.14 s).
create publication pub_6525_to_6526;
alter  publication pub_6525_to_6526 add table pgbench_accounts;
alter  publication pub_6525_to_6526 add table pgbench_branches;
alter  publication pub_6525_to_6526 add table pgbench_tellers;
alter  publication pub_6525_to_6526 add table pgbench_history;
create publication pub_6526_to_6527;
alter  publication pub_6526_to_6527 add table pgbench_accounts;
alter  publication pub_6526_to_6527 add table pgbench_branches;
alter  publication pub_6526_to_6527 add table pgbench_tellers;
alter  publication pub_6526_to_6527 add table pgbench_history;
create publication pub_6527_to_6528;
alter  publication pub_6527_to_6528 add table pgbench_accounts;
alter  publication pub_6527_to_6528 add table pgbench_branches;
alter  publication pub_6527_to_6528 add table pgbench_tellers;
alter  publication pub_6527_to_6528 add table pgbench_history;
create publication pub_6528_to_6529;
alter  publication pub_6528_to_6529 add table pgbench_accounts;
alter  publication pub_6528_to_6529 add table pgbench_branches;
alter  publication pub_6528_to_6529 add table pgbench_tellers;
alter  publication pub_6528_to_6529 add table pgbench_history;
create subscription pub_6527_from_6526 connection 'port=6526 application_name=two_phase'
       publication  pub_6526_to_6527 with(enabled=false);
alter  subscription pub_6527_from_6526 enable;
create subscription pub_6528_from_6527 connection 'port=6527 application_name=two_phase'
       publication  pub_6527_to_6528 with(enabled=false);
alter  subscription pub_6528_from_6527 enable;
create subscription pub_6529_from_6528 connection 'port=6528 application_name=two_phase'
       publication  pub_6528_to_6529 with(enabled=false);
alter  subscription pub_6529_from_6528 enable;
create subscription pub_6526_from_6525 connection 'port=6525 application_name=two_phase'
       publication  pub_6525_to_6526 with(enabled=false);
alter  subscription pub_6526_from_6525 enable;
-- pgbench -p 6525 -c 1 -j 8 -T 1 -n postgres    #  scale 1
pgbench (PostgreSQL) 14.0
transaction type: <builtin: TPC-B (sort of)>
scaling factor: 1
query mode: simple
number of clients: 1
number of threads: 1
duration: 1 s
number of transactions actually processed: 208
latency average = 4.799 ms
initial connection time = 5.543 ms
tps = 208.394491 (without initial connection time)

       accounts branches tellers  history
       -------- -------- -------- --------
6525   17e5e5b3 58312615 09335247 a959e668    3438e543 
6526   d41d8cd9 58312615 09335247 a959e668    0d797b5d 
6527   d41d8cd9 58312615 09335247 a959e668    0d797b5d 
6528   d41d8cd9 58312615 09335247 a959e668    0d797b5d 
6529   d41d8cd9 1ef0c1f3 83e5a516 0b8f4df7    80cac3f6   NOK (1s)                         [two_phase]   scale [1]

6525   17e5e5b3 58312615 09335247 a959e668    3438e543 
6526   17e5e5b3 58312615 09335247 a959e668    3438e543 
6527   d41d8cd9 58312615 09335247 a959e668    0d797b5d 
6528   d41d8cd9 58312615 09335247 a959e668    0d797b5d 
6529   d41d8cd9 58312615 09335247 a959e668    0d797b5d   NOK (1s)                         [two_phase]   scale [1]

6525   17e5e5b3 58312615 09335247 a959e668    3438e543 
6526   17e5e5b3 58312615 09335247 a959e668    3438e543 
6527   17e5e5b3 58312615 09335247 a959e668    3438e543 
6528   d41d8cd9 58312615 09335247 a959e668    0d797b5d 
6529   d41d8cd9 58312615 09335247 a959e668    0d797b5d   NOK (1s)                         [two_phase]   scale [1]

6525   17e5e5b3 58312615 09335247 a959e668    3438e543 
6526   17e5e5b3 58312615 09335247 a959e668    3438e543 
6527   17e5e5b3 58312615 09335247 a959e668    3438e543 
6528   17e5e5b3 58312615 09335247 a959e668    3438e543 
6529   17e5e5b3 58312615 09335247 a959e668    3438e543    ok

  oid  |     pubname      | pubowner | puballtables | pubinsert | pubupdate | pubdelete | pubtruncate | pubviaroot 
-------+------------------+----------+--------------+-----------+-----------+-----------+-------------+------------
 16414 | pub_6525_to_6526 |       10 | f            | t         | t         | t         | t           | f

 oid | subdbid | subname | subowner | subenabled | subbinary | substream | subtwophasestate | subconninfo | subslotname | subsynccommit | subpublications 
-----+---------+---------+----------+------------+-----------+-----------+------------------+-------------+-------------+---------------+-----------------


  oid  |     pubname      | pubowner | puballtables | pubinsert | pubupdate | pubdelete | pubtruncate | pubviaroot 
-------+------------------+----------+--------------+-----------+-----------+-----------+-------------+------------
 16406 | pub_6526_to_6527 |       10 | f            | t         | t         | t         | t           | f

  oid  | subdbid |      subname       | subowner | subenabled | subbinary | substream | subtwophasestate |             subconninfo              |    subslotname     | subsynccommit |  subpublications   
-------+---------+--------------------+----------+------------+-----------+-----------+------------------+--------------------------------------+--------------------+---------------+--------------------
 16411 |   13885 | pub_6526_from_6525 |       10 | t          | f         | f         | d                | port=6525 application_name=two_phase | pub_6526_from_6525 | off           | {pub_6525_to_6526}


  oid  | subdbid |      subname       | subowner | subenabled | subbinary | substream | subtwophasestate |             subconninfo              |    subslotname     | subsynccommit |  subpublications   
-------+---------+--------------------+----------+------------+-----------+-----------+------------------+--------------------------------------+--------------------+---------------+--------------------
 16411 |   13885 | pub_6527_from_6526 |       10 | t          | f         | f         | d                | port=6526 application_name=two_phase | pub_6527_from_6526 | off           | {pub_6526_to_6527}


  oid  | subdbid |      subname       | subowner | subenabled | subbinary | substream | subtwophasestate |             subconninfo              |    subslotname     | subsynccommit |  subpublications   
-------+---------+--------------------+----------+------------+-----------+-----------+------------------+--------------------------------------+--------------------+---------------+--------------------
 16411 |   13885 | pub_6528_from_6527 |       10 | t          | f         | f         | d                | port=6527 application_name=two_phase | pub_6528_from_6527 | off           | {pub_6527_to_6528}


  oid  | subdbid |      subname       | subowner | subenabled | subbinary | substream | subtwophasestate |             subconninfo              |    subslotname     | subsynccommit |  subpublications   
-------+---------+--------------------+----------+------------+-----------+-----------+------------------+--------------------------------------+--------------------+---------------+--------------------
 16406 |   13885 | pub_6529_from_6528 |       10 | t          | f         | f         | d                | port=6528 application_name=two_phase | pub_6529_from_6528 | off           | {pub_6528_to_6529}


waiting for server to shut down.... done
server stopped
waiting for server to shut down.... done
server stopped
waiting for server to shut down.... done
server stopped
waiting for server to shut down.... done
server stopped
waiting for server to shut down.... done
server stopped
[ajin@localhost twophasetest]$