From 00fb2051ffc1d936ecaced9de9734039a62e7553 Mon Sep 17 00:00:00 2001 From: Andrew Davis <1709934+Savid@users.noreply.github.com> Date: Wed, 10 Apr 2024 15:03:58 +1000 Subject: [PATCH] fix(migrations): missing migration --- .../clickhouse/029_remove_ttl.down.sql | 1 + .../clickhouse/029_remove_ttl.up.sql | 1 + ...x_replacing_tables_sharding_keys.down.sql} | 0 ...fix_replacing_tables_sharding_keys.up.sql} | 27 +++++++++---------- ...wn.sql => 031_v1_proposer_duties.down.sql} | 0 ...s.up.sql => 031_v1_proposer_duties.up.sql} | 0 6 files changed, 15 insertions(+), 14 deletions(-) create mode 100644 deploy/migrations/clickhouse/029_remove_ttl.down.sql create mode 100644 deploy/migrations/clickhouse/029_remove_ttl.up.sql rename deploy/migrations/clickhouse/{029_fix_replacing_tables_sharding_keys.down.sql => 030_fix_replacing_tables_sharding_keys.down.sql} (100%) rename deploy/migrations/clickhouse/{029_fix_replacing_tables_sharding_keys.up.sql => 030_fix_replacing_tables_sharding_keys.up.sql} (78%) rename deploy/migrations/clickhouse/{030_v1_proposer_duties.down.sql => 031_v1_proposer_duties.down.sql} (100%) rename deploy/migrations/clickhouse/{030_v1_proposer_duties.up.sql => 031_v1_proposer_duties.up.sql} (100%) diff --git a/deploy/migrations/clickhouse/029_remove_ttl.down.sql b/deploy/migrations/clickhouse/029_remove_ttl.down.sql new file mode 100644 index 00000000..c21641b6 --- /dev/null +++ b/deploy/migrations/clickhouse/029_remove_ttl.down.sql @@ -0,0 +1 @@ +-- empty on purpose \ No newline at end of file diff --git a/deploy/migrations/clickhouse/029_remove_ttl.up.sql b/deploy/migrations/clickhouse/029_remove_ttl.up.sql new file mode 100644 index 00000000..c21641b6 --- /dev/null +++ b/deploy/migrations/clickhouse/029_remove_ttl.up.sql @@ -0,0 +1 @@ +-- empty on purpose \ No newline at end of file diff --git a/deploy/migrations/clickhouse/029_fix_replacing_tables_sharding_keys.down.sql b/deploy/migrations/clickhouse/030_fix_replacing_tables_sharding_keys.down.sql similarity index 100% rename from deploy/migrations/clickhouse/029_fix_replacing_tables_sharding_keys.down.sql rename to deploy/migrations/clickhouse/030_fix_replacing_tables_sharding_keys.down.sql diff --git a/deploy/migrations/clickhouse/029_fix_replacing_tables_sharding_keys.up.sql b/deploy/migrations/clickhouse/030_fix_replacing_tables_sharding_keys.up.sql similarity index 78% rename from deploy/migrations/clickhouse/029_fix_replacing_tables_sharding_keys.up.sql rename to deploy/migrations/clickhouse/030_fix_replacing_tables_sharding_keys.up.sql index f03712c9..5760bf06 100644 --- a/deploy/migrations/clickhouse/029_fix_replacing_tables_sharding_keys.up.sql +++ b/deploy/migrations/clickhouse/030_fix_replacing_tables_sharding_keys.up.sql @@ -4,31 +4,31 @@ ENGINE = Distributed('{cluster}', default, canonical_beacon_block_local, cityHas DROP TABLE IF EXISTS canonical_beacon_block_proposer_slashing on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_block_proposer_slashing on cluster '{cluster}' AS canonical_beacon_block_proposer_slashing_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_block_proposer_slashing_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_block_proposer_slashing_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_block_attester_slashing on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_block_attester_slashing on cluster '{cluster}' AS canonical_beacon_block_attester_slashing_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_block_attester_slashing_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_block_attester_slashing_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_block_bls_to_execution_change on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_block_bls_to_execution_change on cluster '{cluster}' AS canonical_beacon_block_bls_to_execution_change_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_block_bls_to_execution_change_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_block_bls_to_execution_change_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_block_execution_transaction on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_block_execution_transaction on cluster '{cluster}' AS canonical_beacon_block_execution_transaction_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_block_execution_transaction_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_block_execution_transaction_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_block_voluntary_exit on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_block_voluntary_exit on cluster '{cluster}' AS canonical_beacon_block_voluntary_exit_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_block_voluntary_exit_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_block_voluntary_exit_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_block_deposit on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_block_deposit on cluster '{cluster}' AS canonical_beacon_block_deposit_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_block_deposit_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_block_deposit_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_block_withdrawal on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_block_withdrawal on cluster '{cluster}' AS canonical_beacon_block_withdrawal_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_block_withdrawal_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_block_withdrawal_local, unique_key); DROP TABLE IF EXISTS beacon_block_classification on cluster '{cluster}' SYNC; CREATE TABLE beacon_block_classification on cluster '{cluster}' AS beacon_block_classification_local @@ -36,25 +36,24 @@ ENGINE = Distributed('{cluster}', default, beacon_block_classification_local, ci DROP TABLE IF EXISTS canonical_beacon_blob_sidecar on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_blob_sidecar on cluster '{cluster}' AS canonical_beacon_blob_sidecar_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_blob_sidecar_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_blob_sidecar_local, unique_key); DROP TABLE IF EXISTS mempool_dumpster_transaction on cluster '{cluster}' SYNC; CREATE TABLE mempool_dumpster_transaction on cluster '{cluster}' AS mempool_dumpster_transaction_local -ENGINE = Distributed('{cluster}', default, mempool_dumpster_transaction_local, cityHash64(timestamp, unique_key, chain_id)); +ENGINE = Distributed('{cluster}', default, mempool_dumpster_transaction_local, unique_key); DROP TABLE IF EXISTS block_native_mempool_transaction on cluster '{cluster}' SYNC; CREATE TABLE block_native_mempool_transaction on cluster '{cluster}' AS block_native_mempool_transaction_local -ENGINE = Distributed('{cluster}', default, block_native_mempool_transaction_local, cityHash64(detecttime, unique_key, network)); +ENGINE = Distributed('{cluster}', default, block_native_mempool_transaction_local, unique_key); DROP TABLE IF EXISTS beacon_p2p_attestation on cluster '{cluster}' SYNC; CREATE TABLE beacon_p2p_attestation on cluster '{cluster}' AS beacon_p2p_attestation_local -ENGINE = Distributed('{cluster}', default, beacon_p2p_attestation_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, beacon_p2p_attestation_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_proposer_duty on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_proposer_duty on cluster '{cluster}' AS canonical_beacon_proposer_duty_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_proposer_duty_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); +ENGINE = Distributed('{cluster}', default, canonical_beacon_proposer_duty_local, unique_key); DROP TABLE IF EXISTS canonical_beacon_elaborated_attestation on cluster '{cluster}' SYNC; CREATE TABLE canonical_beacon_elaborated_attestation on cluster '{cluster}' AS canonical_beacon_elaborated_attestation_local -ENGINE = Distributed('{cluster}', default, canonical_beacon_elaborated_attestation_local, cityHash64(slot_start_date_time, unique_key, meta_network_name)); - +ENGINE = Distributed('{cluster}', default, canonical_beacon_elaborated_attestation_local, unique_key); diff --git a/deploy/migrations/clickhouse/030_v1_proposer_duties.down.sql b/deploy/migrations/clickhouse/031_v1_proposer_duties.down.sql similarity index 100% rename from deploy/migrations/clickhouse/030_v1_proposer_duties.down.sql rename to deploy/migrations/clickhouse/031_v1_proposer_duties.down.sql diff --git a/deploy/migrations/clickhouse/030_v1_proposer_duties.up.sql b/deploy/migrations/clickhouse/031_v1_proposer_duties.up.sql similarity index 100% rename from deploy/migrations/clickhouse/030_v1_proposer_duties.up.sql rename to deploy/migrations/clickhouse/031_v1_proposer_duties.up.sql