blockworks-foundation / bankingstageerrorstrackingsidecar Goto Github PK

2024-02-08 14:15:32.131 CET [10326] bankingstage_sidecar@banking_stage ERROR:  deadlock detected
2024-02-08 14:15:32.131 CET [10326] bankingstage_sidecar@banking_stage DETAIL:  Process 10326 waits for Share
Lock on transaction 2245819; blocked by process 10328.
        Process 10328 waits for ShareLock on transaction 2245818; blocked by process 10326.
        Process 10326:
                INSERT INTO banking_stage_results_2.accounts(account_key) SELECT key from temp_table_2_22322
                ON CONFLICT DO NOTHING

        Process 10328:
                INSERT INTO banking_stage_results_2.accounts(account_key) SELECT key from temp_table_4_22308
                ON CONFLICT DO NOTHING

SELECT
	array_dedup_append('{8,3,2,1}', '{5,3}', 4),-- {2,1,5,3}
	array_dedup_append('{8,3,2,1}', '{5,3}', 10000) -- {8,2,1,5,3}

CREATE TABLE banking_stage_results_2.accounts_map_transaction_latest_parted(
    acc_id BIGINT PRIMARY KEY,
    tx_ids BIGINT[]
) PARTITION BY HASH (acc_id);


DO $$
    DECLARE part_no integer;
	DECLARE num_parts integer := 4;
BEGIN
    for part_no in 0..num_parts-1 loop
        EXECUTE format(
			'
			CREATE TABLE banking_stage_results_2.accounts_map_transaction_latest_part%s
			PARTITION OF banking_stage_results_2.accounts_map_transaction_latest_parted
			FOR VALUES WITH (MODULUS %s, REMAINDER %s)
			WITH (FILLFACTOR=80)
			', part_no, num_parts, part_no);
    end loop;
END; $$

INSERT INTO banking_stage_results_2.accounts_map_transaction_latest_parted
SELECT * FROM banking_stage_results_2.accounts_map_transaction_latest;

SELECT count(*) FROM banking_stage_results_2.accounts_map_transaction_latest;

ALTER TABLE banking_stage_results_2.accounts_map_transaction_latest RENAME TO accounts_map_transaction_latest_unparted_old;
ALTER TABLE banking_stage_results_2.accounts_map_transaction_latest_parted RENAME TO accounts_map_transaction_latest;

SELECT count(*) FROM banking_stage_results_2.accounts_map_transaction_latest;

DROP TABLE banking_stage_results_2.accounts_map_transaction_latest_unparted_old;