From 360537bc42842bef1ac267b049b2ca59200a58ad Mon Sep 17 00:00:00 2001 From: Jelte Fennema Date: Mon, 6 Mar 2023 10:53:12 +0100 Subject: [PATCH] Use pg_total_relation_size in citus_shards (#6748) DESCRIPTION: Correctly report shard size in citus_shards view When looking at citus_shards, people are interested in the actual size that all the data related to the shard takes up on disk. `pg_total_relation_size` is the function to use for that purpose. The previously used `pg_relation_size` does not include indexes or TOAST. Especially the missing toast can have enormous impact on the size of the shown data. (cherry picked from commit b489d763e169b4b2ed4accc3a2337e97a58fd716) --- .../distributed/metadata/metadata_utility.c | 2 +- .../citus_update_table_statistics.out | 8 +- .../expected/multi_mx_create_table.out | 428 +++++++++--------- 3 files changed, 219 insertions(+), 219 deletions(-) diff --git a/src/backend/distributed/metadata/metadata_utility.c b/src/backend/distributed/metadata/metadata_utility.c index 2fd84d239..f08b94fe3 100644 --- a/src/backend/distributed/metadata/metadata_utility.c +++ b/src/backend/distributed/metadata/metadata_utility.c @@ -916,7 +916,7 @@ AppendShardSizeQuery(StringInfo selectQuery, ShardInterval *shardInterval) appendStringInfo(selectQuery, "SELECT " UINT64_FORMAT " AS shard_id, ", shardId); appendStringInfo(selectQuery, "%s AS shard_name, ", quotedShardName); - appendStringInfo(selectQuery, PG_RELATION_SIZE_FUNCTION, quotedShardName); + appendStringInfo(selectQuery, PG_TOTAL_RELATION_SIZE_FUNCTION, quotedShardName); } diff --git a/src/test/regress/expected/citus_update_table_statistics.out b/src/test/regress/expected/citus_update_table_statistics.out index 69676c1bf..031104c53 100644 --- a/src/test/regress/expected/citus_update_table_statistics.out +++ b/src/test/regress/expected/citus_update_table_statistics.out @@ -64,11 +64,11 @@ SET citus.multi_shard_modify_mode TO sequential; SELECT citus_update_table_statistics('test_table_statistics_hash'); NOTICE: issuing BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED;SELECT assign_distributed_transaction_id(xx, xx, 'xxxxxxx'); DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing SELECT 981000 AS shard_id, 'public.test_table_statistics_hash_981000' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981000') UNION ALL SELECT 981001 AS shard_id, 'public.test_table_statistics_hash_981001' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981001') UNION ALL SELECT 981002 AS shard_id, 'public.test_table_statistics_hash_981002' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981002') UNION ALL SELECT 981003 AS shard_id, 'public.test_table_statistics_hash_981003' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981003') UNION ALL SELECT 981004 AS shard_id, 'public.test_table_statistics_hash_981004' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981004') UNION ALL SELECT 981005 AS shard_id, 'public.test_table_statistics_hash_981005' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981005') UNION ALL SELECT 981006 AS shard_id, 'public.test_table_statistics_hash_981006' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981006') UNION ALL SELECT 981007 AS shard_id, 'public.test_table_statistics_hash_981007' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981007') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; +NOTICE: issuing SELECT 981000 AS shard_id, 'public.test_table_statistics_hash_981000' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981000') UNION ALL SELECT 981001 AS shard_id, 'public.test_table_statistics_hash_981001' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981001') UNION ALL SELECT 981002 AS shard_id, 'public.test_table_statistics_hash_981002' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981002') UNION ALL SELECT 981003 AS shard_id, 'public.test_table_statistics_hash_981003' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981003') UNION ALL SELECT 981004 AS shard_id, 'public.test_table_statistics_hash_981004' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981004') UNION ALL SELECT 981005 AS shard_id, 'public.test_table_statistics_hash_981005' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981005') UNION ALL SELECT 981006 AS shard_id, 'public.test_table_statistics_hash_981006' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981006') UNION ALL SELECT 981007 AS shard_id, 'public.test_table_statistics_hash_981007' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981007') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED;SELECT assign_distributed_transaction_id(xx, xx, 'xxxxxxx'); DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing SELECT 981000 AS shard_id, 'public.test_table_statistics_hash_981000' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981000') UNION ALL SELECT 981001 AS shard_id, 'public.test_table_statistics_hash_981001' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981001') UNION ALL SELECT 981002 AS shard_id, 'public.test_table_statistics_hash_981002' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981002') UNION ALL SELECT 981003 AS shard_id, 'public.test_table_statistics_hash_981003' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981003') UNION ALL SELECT 981004 AS shard_id, 'public.test_table_statistics_hash_981004' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981004') UNION ALL SELECT 981005 AS shard_id, 'public.test_table_statistics_hash_981005' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981005') UNION ALL SELECT 981006 AS shard_id, 'public.test_table_statistics_hash_981006' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981006') UNION ALL SELECT 981007 AS shard_id, 'public.test_table_statistics_hash_981007' AS shard_name, pg_relation_size('public.test_table_statistics_hash_981007') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; +NOTICE: issuing SELECT 981000 AS shard_id, 'public.test_table_statistics_hash_981000' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981000') UNION ALL SELECT 981001 AS shard_id, 'public.test_table_statistics_hash_981001' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981001') UNION ALL SELECT 981002 AS shard_id, 'public.test_table_statistics_hash_981002' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981002') UNION ALL SELECT 981003 AS shard_id, 'public.test_table_statistics_hash_981003' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981003') UNION ALL SELECT 981004 AS shard_id, 'public.test_table_statistics_hash_981004' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981004') UNION ALL SELECT 981005 AS shard_id, 'public.test_table_statistics_hash_981005' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981005') UNION ALL SELECT 981006 AS shard_id, 'public.test_table_statistics_hash_981006' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981006') UNION ALL SELECT 981007 AS shard_id, 'public.test_table_statistics_hash_981007' AS shard_name, pg_total_relation_size('public.test_table_statistics_hash_981007') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing COMMIT DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx @@ -152,11 +152,11 @@ SET citus.multi_shard_modify_mode TO sequential; SELECT citus_update_table_statistics('test_table_statistics_append'); NOTICE: issuing BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED;SELECT assign_distributed_transaction_id(xx, xx, 'xxxxxxx'); DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing SELECT 981008 AS shard_id, 'public.test_table_statistics_append_981008' AS shard_name, pg_relation_size('public.test_table_statistics_append_981008') UNION ALL SELECT 981009 AS shard_id, 'public.test_table_statistics_append_981009' AS shard_name, pg_relation_size('public.test_table_statistics_append_981009') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; +NOTICE: issuing SELECT 981008 AS shard_id, 'public.test_table_statistics_append_981008' AS shard_name, pg_total_relation_size('public.test_table_statistics_append_981008') UNION ALL SELECT 981009 AS shard_id, 'public.test_table_statistics_append_981009' AS shard_name, pg_total_relation_size('public.test_table_statistics_append_981009') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED;SELECT assign_distributed_transaction_id(xx, xx, 'xxxxxxx'); DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing SELECT 981008 AS shard_id, 'public.test_table_statistics_append_981008' AS shard_name, pg_relation_size('public.test_table_statistics_append_981008') UNION ALL SELECT 981009 AS shard_id, 'public.test_table_statistics_append_981009' AS shard_name, pg_relation_size('public.test_table_statistics_append_981009') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; +NOTICE: issuing SELECT 981008 AS shard_id, 'public.test_table_statistics_append_981008' AS shard_name, pg_total_relation_size('public.test_table_statistics_append_981008') UNION ALL SELECT 981009 AS shard_id, 'public.test_table_statistics_append_981009' AS shard_name, pg_total_relation_size('public.test_table_statistics_append_981009') UNION ALL SELECT 0::bigint, NULL::text, 0::bigint; DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing COMMIT DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx diff --git a/src/test/regress/expected/multi_mx_create_table.out b/src/test/regress/expected/multi_mx_create_table.out index 6036bd325..1e46276b5 100644 --- a/src/test/regress/expected/multi_mx_create_table.out +++ b/src/test/regress/expected/multi_mx_create_table.out @@ -496,22 +496,22 @@ ORDER BY table_name::text; SELECT shard_name, table_name, citus_table_type, shard_size FROM citus_shards ORDER BY shard_name::text; shard_name | table_name | citus_table_type | shard_size --------------------------------------------------------------------- - app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220097 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 0 - app_analytics_events_mx_1220099 | app_analytics_events_mx | distributed | 0 + app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220096 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220097 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220098 | app_analytics_events_mx | distributed | 8192 + app_analytics_events_mx_1220099 | app_analytics_events_mx | distributed | 8192 articles_hash_mx_1220104 | articles_hash_mx | distributed | 0 articles_hash_mx_1220104 | articles_hash_mx | distributed | 0 articles_hash_mx_1220104 | articles_hash_mx | distributed | 0 @@ -607,22 +607,22 @@ SELECT shard_name, table_name, citus_table_type, shard_size FROM citus_shards OR citus_mx_test_schema.nation_hash_collation_search_path_1220046 | citus_mx_test_schema.nation_hash_collation_search_path | distributed | 0 citus_mx_test_schema.nation_hash_collation_search_path_1220046 | citus_mx_test_schema.nation_hash_collation_search_path | distributed | 0 citus_mx_test_schema.nation_hash_collation_search_path_1220047 | citus_mx_test_schema.nation_hash_collation_search_path | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220049 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 - citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 0 - citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 0 - citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 0 - citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 0 - citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 0 - citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 0 - citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 0 - citus_mx_test_schema.nation_hash_composite_types_1220051 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220048 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220049 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 + citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220050 | citus_mx_test_schema.nation_hash_composite_types | distributed | 8192 + citus_mx_test_schema.nation_hash_composite_types_1220051 | citus_mx_test_schema.nation_hash_composite_types | distributed | 16384 citus_mx_test_schema_join_1.nation_hash_1220032 | citus_mx_test_schema_join_1.nation_hash | distributed | 0 citus_mx_test_schema_join_1.nation_hash_1220032 | citus_mx_test_schema_join_1.nation_hash | distributed | 0 citus_mx_test_schema_join_1.nation_hash_1220032 | citus_mx_test_schema_join_1.nation_hash | distributed | 0 @@ -695,109 +695,109 @@ SELECT shard_name, table_name, citus_table_type, shard_size FROM citus_shards OR customer_mx_1220084 | customer_mx | reference | 0 customer_mx_1220084 | customer_mx | reference | 0 customer_mx_1220084 | customer_mx | reference | 0 - labs_mx_1220102 | labs_mx | distributed | 0 - labs_mx_1220102 | labs_mx | distributed | 0 - labs_mx_1220102 | labs_mx | distributed | 0 - labs_mx_1220102 | labs_mx | distributed | 0 - labs_mx_1220102 | labs_mx | distributed | 0 - labs_mx_1220102 | labs_mx | distributed | 0 - labs_mx_1220102 | labs_mx | distributed | 0 - limit_orders_mx_1220092 | limit_orders_mx | distributed | 0 - limit_orders_mx_1220092 | limit_orders_mx | distributed | 0 - limit_orders_mx_1220092 | limit_orders_mx | distributed | 0 - limit_orders_mx_1220092 | limit_orders_mx | distributed | 0 - limit_orders_mx_1220092 | limit_orders_mx | distributed | 0 - limit_orders_mx_1220092 | limit_orders_mx | distributed | 0 - limit_orders_mx_1220092 | limit_orders_mx | distributed | 0 - limit_orders_mx_1220093 | limit_orders_mx | distributed | 0 - lineitem_mx_1220052 | lineitem_mx | distributed | 0 - lineitem_mx_1220052 | lineitem_mx | distributed | 0 - lineitem_mx_1220052 | lineitem_mx | distributed | 0 - lineitem_mx_1220052 | lineitem_mx | distributed | 0 - lineitem_mx_1220052 | lineitem_mx | distributed | 0 - lineitem_mx_1220052 | lineitem_mx | distributed | 0 - lineitem_mx_1220052 | lineitem_mx | distributed | 0 - lineitem_mx_1220053 | lineitem_mx | distributed | 0 - lineitem_mx_1220054 | lineitem_mx | distributed | 0 - lineitem_mx_1220054 | lineitem_mx | distributed | 0 - lineitem_mx_1220054 | lineitem_mx | distributed | 0 - lineitem_mx_1220054 | lineitem_mx | distributed | 0 - lineitem_mx_1220054 | lineitem_mx | distributed | 0 - lineitem_mx_1220054 | lineitem_mx | distributed | 0 - lineitem_mx_1220054 | lineitem_mx | distributed | 0 - lineitem_mx_1220055 | lineitem_mx | distributed | 0 - lineitem_mx_1220056 | lineitem_mx | distributed | 0 - lineitem_mx_1220056 | lineitem_mx | distributed | 0 - lineitem_mx_1220056 | lineitem_mx | distributed | 0 - lineitem_mx_1220056 | lineitem_mx | distributed | 0 - lineitem_mx_1220056 | lineitem_mx | distributed | 0 - lineitem_mx_1220056 | lineitem_mx | distributed | 0 - lineitem_mx_1220056 | lineitem_mx | distributed | 0 - lineitem_mx_1220057 | lineitem_mx | distributed | 0 - lineitem_mx_1220058 | lineitem_mx | distributed | 0 - lineitem_mx_1220058 | lineitem_mx | distributed | 0 - lineitem_mx_1220058 | lineitem_mx | distributed | 0 - lineitem_mx_1220058 | lineitem_mx | distributed | 0 - lineitem_mx_1220058 | lineitem_mx | distributed | 0 - lineitem_mx_1220058 | lineitem_mx | distributed | 0 - lineitem_mx_1220058 | lineitem_mx | distributed | 0 - lineitem_mx_1220059 | lineitem_mx | distributed | 0 - lineitem_mx_1220060 | lineitem_mx | distributed | 0 - lineitem_mx_1220060 | lineitem_mx | distributed | 0 - lineitem_mx_1220060 | lineitem_mx | distributed | 0 - lineitem_mx_1220060 | lineitem_mx | distributed | 0 - lineitem_mx_1220060 | lineitem_mx | distributed | 0 - lineitem_mx_1220060 | lineitem_mx | distributed | 0 - lineitem_mx_1220060 | lineitem_mx | distributed | 0 - lineitem_mx_1220061 | lineitem_mx | distributed | 0 - lineitem_mx_1220062 | lineitem_mx | distributed | 0 - lineitem_mx_1220062 | lineitem_mx | distributed | 0 - lineitem_mx_1220062 | lineitem_mx | distributed | 0 - lineitem_mx_1220062 | lineitem_mx | distributed | 0 - lineitem_mx_1220062 | lineitem_mx | distributed | 0 - lineitem_mx_1220062 | lineitem_mx | distributed | 0 - lineitem_mx_1220062 | lineitem_mx | distributed | 0 - lineitem_mx_1220063 | lineitem_mx | distributed | 0 - lineitem_mx_1220064 | lineitem_mx | distributed | 0 - lineitem_mx_1220064 | lineitem_mx | distributed | 0 - lineitem_mx_1220064 | lineitem_mx | distributed | 0 - lineitem_mx_1220064 | lineitem_mx | distributed | 0 - lineitem_mx_1220064 | lineitem_mx | distributed | 0 - lineitem_mx_1220064 | lineitem_mx | distributed | 0 - lineitem_mx_1220064 | lineitem_mx | distributed | 0 - lineitem_mx_1220065 | lineitem_mx | distributed | 0 - lineitem_mx_1220066 | lineitem_mx | distributed | 0 - lineitem_mx_1220066 | lineitem_mx | distributed | 0 - lineitem_mx_1220066 | lineitem_mx | distributed | 0 - lineitem_mx_1220066 | lineitem_mx | distributed | 0 - lineitem_mx_1220066 | lineitem_mx | distributed | 0 - lineitem_mx_1220066 | lineitem_mx | distributed | 0 - lineitem_mx_1220066 | lineitem_mx | distributed | 0 - lineitem_mx_1220067 | lineitem_mx | distributed | 0 - multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 0 - multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 0 - multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 0 - multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 0 - multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 0 - multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 0 - multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 0 - multiple_hash_mx_1220095 | multiple_hash_mx | distributed | 0 - mx_ddl_table_1220088 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220088 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220088 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220088 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220088 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220088 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220088 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220089 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220090 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220090 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220090 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220090 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220090 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220090 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220090 | mx_ddl_table | distributed | 8192 - mx_ddl_table_1220091 | mx_ddl_table | distributed | 8192 + labs_mx_1220102 | labs_mx | distributed | 8192 + labs_mx_1220102 | labs_mx | distributed | 8192 + labs_mx_1220102 | labs_mx | distributed | 8192 + labs_mx_1220102 | labs_mx | distributed | 8192 + labs_mx_1220102 | labs_mx | distributed | 8192 + labs_mx_1220102 | labs_mx | distributed | 8192 + labs_mx_1220102 | labs_mx | distributed | 8192 + limit_orders_mx_1220092 | limit_orders_mx | distributed | 16384 + limit_orders_mx_1220092 | limit_orders_mx | distributed | 16384 + limit_orders_mx_1220092 | limit_orders_mx | distributed | 16384 + limit_orders_mx_1220092 | limit_orders_mx | distributed | 16384 + limit_orders_mx_1220092 | limit_orders_mx | distributed | 16384 + limit_orders_mx_1220092 | limit_orders_mx | distributed | 16384 + limit_orders_mx_1220092 | limit_orders_mx | distributed | 16384 + limit_orders_mx_1220093 | limit_orders_mx | distributed | 16384 + lineitem_mx_1220052 | lineitem_mx | distributed | 16384 + lineitem_mx_1220052 | lineitem_mx | distributed | 16384 + lineitem_mx_1220052 | lineitem_mx | distributed | 16384 + lineitem_mx_1220052 | lineitem_mx | distributed | 16384 + lineitem_mx_1220052 | lineitem_mx | distributed | 16384 + lineitem_mx_1220052 | lineitem_mx | distributed | 16384 + lineitem_mx_1220052 | lineitem_mx | distributed | 16384 + lineitem_mx_1220053 | lineitem_mx | distributed | 16384 + lineitem_mx_1220054 | lineitem_mx | distributed | 16384 + lineitem_mx_1220054 | lineitem_mx | distributed | 16384 + lineitem_mx_1220054 | lineitem_mx | distributed | 16384 + lineitem_mx_1220054 | lineitem_mx | distributed | 16384 + lineitem_mx_1220054 | lineitem_mx | distributed | 16384 + lineitem_mx_1220054 | lineitem_mx | distributed | 16384 + lineitem_mx_1220054 | lineitem_mx | distributed | 16384 + lineitem_mx_1220055 | lineitem_mx | distributed | 16384 + lineitem_mx_1220056 | lineitem_mx | distributed | 16384 + lineitem_mx_1220056 | lineitem_mx | distributed | 16384 + lineitem_mx_1220056 | lineitem_mx | distributed | 16384 + lineitem_mx_1220056 | lineitem_mx | distributed | 16384 + lineitem_mx_1220056 | lineitem_mx | distributed | 16384 + lineitem_mx_1220056 | lineitem_mx | distributed | 16384 + lineitem_mx_1220056 | lineitem_mx | distributed | 16384 + lineitem_mx_1220057 | lineitem_mx | distributed | 16384 + lineitem_mx_1220058 | lineitem_mx | distributed | 16384 + lineitem_mx_1220058 | lineitem_mx | distributed | 16384 + lineitem_mx_1220058 | lineitem_mx | distributed | 16384 + lineitem_mx_1220058 | lineitem_mx | distributed | 16384 + lineitem_mx_1220058 | lineitem_mx | distributed | 16384 + lineitem_mx_1220058 | lineitem_mx | distributed | 16384 + lineitem_mx_1220058 | lineitem_mx | distributed | 16384 + lineitem_mx_1220059 | lineitem_mx | distributed | 16384 + lineitem_mx_1220060 | lineitem_mx | distributed | 16384 + lineitem_mx_1220060 | lineitem_mx | distributed | 16384 + lineitem_mx_1220060 | lineitem_mx | distributed | 16384 + lineitem_mx_1220060 | lineitem_mx | distributed | 16384 + lineitem_mx_1220060 | lineitem_mx | distributed | 16384 + lineitem_mx_1220060 | lineitem_mx | distributed | 16384 + lineitem_mx_1220060 | lineitem_mx | distributed | 16384 + lineitem_mx_1220061 | lineitem_mx | distributed | 16384 + lineitem_mx_1220062 | lineitem_mx | distributed | 16384 + lineitem_mx_1220062 | lineitem_mx | distributed | 16384 + lineitem_mx_1220062 | lineitem_mx | distributed | 16384 + lineitem_mx_1220062 | lineitem_mx | distributed | 16384 + lineitem_mx_1220062 | lineitem_mx | distributed | 16384 + lineitem_mx_1220062 | lineitem_mx | distributed | 16384 + lineitem_mx_1220062 | lineitem_mx | distributed | 16384 + lineitem_mx_1220063 | lineitem_mx | distributed | 16384 + lineitem_mx_1220064 | lineitem_mx | distributed | 16384 + lineitem_mx_1220064 | lineitem_mx | distributed | 16384 + lineitem_mx_1220064 | lineitem_mx | distributed | 16384 + lineitem_mx_1220064 | lineitem_mx | distributed | 16384 + lineitem_mx_1220064 | lineitem_mx | distributed | 16384 + lineitem_mx_1220064 | lineitem_mx | distributed | 16384 + lineitem_mx_1220064 | lineitem_mx | distributed | 16384 + lineitem_mx_1220065 | lineitem_mx | distributed | 16384 + lineitem_mx_1220066 | lineitem_mx | distributed | 16384 + lineitem_mx_1220066 | lineitem_mx | distributed | 16384 + lineitem_mx_1220066 | lineitem_mx | distributed | 16384 + lineitem_mx_1220066 | lineitem_mx | distributed | 16384 + lineitem_mx_1220066 | lineitem_mx | distributed | 16384 + lineitem_mx_1220066 | lineitem_mx | distributed | 16384 + lineitem_mx_1220066 | lineitem_mx | distributed | 16384 + lineitem_mx_1220067 | lineitem_mx | distributed | 16384 + multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 8192 + multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 8192 + multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 8192 + multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 8192 + multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 8192 + multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 8192 + multiple_hash_mx_1220094 | multiple_hash_mx | distributed | 8192 + multiple_hash_mx_1220095 | multiple_hash_mx | distributed | 8192 + mx_ddl_table_1220088 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220088 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220088 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220088 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220088 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220088 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220088 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220089 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220090 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220090 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220090 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220090 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220090 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220090 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220090 | mx_ddl_table | distributed | 24576 + mx_ddl_table_1220091 | mx_ddl_table | distributed | 24576 nation_hash_1220000 | nation_hash | distributed | 0 nation_hash_1220000 | nation_hash | distributed | 0 nation_hash_1220000 | nation_hash | distributed | 0 @@ -870,77 +870,77 @@ SELECT shard_name, table_name, citus_table_type, shard_size FROM citus_shards OR nation_mx_1220085 | nation_mx | reference | 0 nation_mx_1220085 | nation_mx | reference | 0 nation_mx_1220085 | nation_mx | reference | 0 - objects_mx_1220103 | objects_mx | distributed | 0 - objects_mx_1220103 | objects_mx | distributed | 0 - objects_mx_1220103 | objects_mx | distributed | 0 - objects_mx_1220103 | objects_mx | distributed | 0 - objects_mx_1220103 | objects_mx | distributed | 0 - objects_mx_1220103 | objects_mx | distributed | 0 - objects_mx_1220103 | objects_mx | distributed | 0 - orders_mx_1220068 | orders_mx | distributed | 0 - orders_mx_1220068 | orders_mx | distributed | 0 - orders_mx_1220068 | orders_mx | distributed | 0 - orders_mx_1220068 | orders_mx | distributed | 0 - orders_mx_1220068 | orders_mx | distributed | 0 - orders_mx_1220068 | orders_mx | distributed | 0 - orders_mx_1220068 | orders_mx | distributed | 0 - orders_mx_1220069 | orders_mx | distributed | 0 - orders_mx_1220070 | orders_mx | distributed | 0 - orders_mx_1220070 | orders_mx | distributed | 0 - orders_mx_1220070 | orders_mx | distributed | 0 - orders_mx_1220070 | orders_mx | distributed | 0 - orders_mx_1220070 | orders_mx | distributed | 0 - orders_mx_1220070 | orders_mx | distributed | 0 - orders_mx_1220070 | orders_mx | distributed | 0 - orders_mx_1220071 | orders_mx | distributed | 0 - orders_mx_1220072 | orders_mx | distributed | 0 - orders_mx_1220072 | orders_mx | distributed | 0 - orders_mx_1220072 | orders_mx | distributed | 0 - orders_mx_1220072 | orders_mx | distributed | 0 - orders_mx_1220072 | orders_mx | distributed | 0 - orders_mx_1220072 | orders_mx | distributed | 0 - orders_mx_1220072 | orders_mx | distributed | 0 - orders_mx_1220073 | orders_mx | distributed | 0 - orders_mx_1220074 | orders_mx | distributed | 0 - orders_mx_1220074 | orders_mx | distributed | 0 - orders_mx_1220074 | orders_mx | distributed | 0 - orders_mx_1220074 | orders_mx | distributed | 0 - orders_mx_1220074 | orders_mx | distributed | 0 - orders_mx_1220074 | orders_mx | distributed | 0 - orders_mx_1220074 | orders_mx | distributed | 0 - orders_mx_1220075 | orders_mx | distributed | 0 - orders_mx_1220076 | orders_mx | distributed | 0 - orders_mx_1220076 | orders_mx | distributed | 0 - orders_mx_1220076 | orders_mx | distributed | 0 - orders_mx_1220076 | orders_mx | distributed | 0 - orders_mx_1220076 | orders_mx | distributed | 0 - orders_mx_1220076 | orders_mx | distributed | 0 - orders_mx_1220076 | orders_mx | distributed | 0 - orders_mx_1220077 | orders_mx | distributed | 0 - orders_mx_1220078 | orders_mx | distributed | 0 - orders_mx_1220078 | orders_mx | distributed | 0 - orders_mx_1220078 | orders_mx | distributed | 0 - orders_mx_1220078 | orders_mx | distributed | 0 - orders_mx_1220078 | orders_mx | distributed | 0 - orders_mx_1220078 | orders_mx | distributed | 0 - orders_mx_1220078 | orders_mx | distributed | 0 - orders_mx_1220079 | orders_mx | distributed | 0 - orders_mx_1220080 | orders_mx | distributed | 0 - orders_mx_1220080 | orders_mx | distributed | 0 - orders_mx_1220080 | orders_mx | distributed | 0 - orders_mx_1220080 | orders_mx | distributed | 0 - orders_mx_1220080 | orders_mx | distributed | 0 - orders_mx_1220080 | orders_mx | distributed | 0 - orders_mx_1220080 | orders_mx | distributed | 0 - orders_mx_1220081 | orders_mx | distributed | 0 - orders_mx_1220082 | orders_mx | distributed | 0 - orders_mx_1220082 | orders_mx | distributed | 0 - orders_mx_1220082 | orders_mx | distributed | 0 - orders_mx_1220082 | orders_mx | distributed | 0 - orders_mx_1220082 | orders_mx | distributed | 0 - orders_mx_1220082 | orders_mx | distributed | 0 - orders_mx_1220082 | orders_mx | distributed | 0 - orders_mx_1220083 | orders_mx | distributed | 0 + objects_mx_1220103 | objects_mx | distributed | 16384 + objects_mx_1220103 | objects_mx | distributed | 16384 + objects_mx_1220103 | objects_mx | distributed | 16384 + objects_mx_1220103 | objects_mx | distributed | 16384 + objects_mx_1220103 | objects_mx | distributed | 16384 + objects_mx_1220103 | objects_mx | distributed | 16384 + objects_mx_1220103 | objects_mx | distributed | 16384 + orders_mx_1220068 | orders_mx | distributed | 8192 + orders_mx_1220068 | orders_mx | distributed | 8192 + orders_mx_1220068 | orders_mx | distributed | 8192 + orders_mx_1220068 | orders_mx | distributed | 8192 + orders_mx_1220068 | orders_mx | distributed | 8192 + orders_mx_1220068 | orders_mx | distributed | 8192 + orders_mx_1220068 | orders_mx | distributed | 8192 + orders_mx_1220069 | orders_mx | distributed | 8192 + orders_mx_1220070 | orders_mx | distributed | 8192 + orders_mx_1220070 | orders_mx | distributed | 8192 + orders_mx_1220070 | orders_mx | distributed | 8192 + orders_mx_1220070 | orders_mx | distributed | 8192 + orders_mx_1220070 | orders_mx | distributed | 8192 + orders_mx_1220070 | orders_mx | distributed | 8192 + orders_mx_1220070 | orders_mx | distributed | 8192 + orders_mx_1220071 | orders_mx | distributed | 8192 + orders_mx_1220072 | orders_mx | distributed | 8192 + orders_mx_1220072 | orders_mx | distributed | 8192 + orders_mx_1220072 | orders_mx | distributed | 8192 + orders_mx_1220072 | orders_mx | distributed | 8192 + orders_mx_1220072 | orders_mx | distributed | 8192 + orders_mx_1220072 | orders_mx | distributed | 8192 + orders_mx_1220072 | orders_mx | distributed | 8192 + orders_mx_1220073 | orders_mx | distributed | 8192 + orders_mx_1220074 | orders_mx | distributed | 8192 + orders_mx_1220074 | orders_mx | distributed | 8192 + orders_mx_1220074 | orders_mx | distributed | 8192 + orders_mx_1220074 | orders_mx | distributed | 8192 + orders_mx_1220074 | orders_mx | distributed | 8192 + orders_mx_1220074 | orders_mx | distributed | 8192 + orders_mx_1220074 | orders_mx | distributed | 8192 + orders_mx_1220075 | orders_mx | distributed | 8192 + orders_mx_1220076 | orders_mx | distributed | 8192 + orders_mx_1220076 | orders_mx | distributed | 8192 + orders_mx_1220076 | orders_mx | distributed | 8192 + orders_mx_1220076 | orders_mx | distributed | 8192 + orders_mx_1220076 | orders_mx | distributed | 8192 + orders_mx_1220076 | orders_mx | distributed | 8192 + orders_mx_1220076 | orders_mx | distributed | 8192 + orders_mx_1220077 | orders_mx | distributed | 8192 + orders_mx_1220078 | orders_mx | distributed | 8192 + orders_mx_1220078 | orders_mx | distributed | 8192 + orders_mx_1220078 | orders_mx | distributed | 8192 + orders_mx_1220078 | orders_mx | distributed | 8192 + orders_mx_1220078 | orders_mx | distributed | 8192 + orders_mx_1220078 | orders_mx | distributed | 8192 + orders_mx_1220078 | orders_mx | distributed | 8192 + orders_mx_1220079 | orders_mx | distributed | 8192 + orders_mx_1220080 | orders_mx | distributed | 8192 + orders_mx_1220080 | orders_mx | distributed | 8192 + orders_mx_1220080 | orders_mx | distributed | 8192 + orders_mx_1220080 | orders_mx | distributed | 8192 + orders_mx_1220080 | orders_mx | distributed | 8192 + orders_mx_1220080 | orders_mx | distributed | 8192 + orders_mx_1220080 | orders_mx | distributed | 8192 + orders_mx_1220081 | orders_mx | distributed | 8192 + orders_mx_1220082 | orders_mx | distributed | 8192 + orders_mx_1220082 | orders_mx | distributed | 8192 + orders_mx_1220082 | orders_mx | distributed | 8192 + orders_mx_1220082 | orders_mx | distributed | 8192 + orders_mx_1220082 | orders_mx | distributed | 8192 + orders_mx_1220082 | orders_mx | distributed | 8192 + orders_mx_1220082 | orders_mx | distributed | 8192 + orders_mx_1220083 | orders_mx | distributed | 8192 part_mx_1220086 | part_mx | reference | 0 part_mx_1220086 | part_mx | reference | 0 part_mx_1220086 | part_mx | reference | 0 @@ -949,14 +949,14 @@ SELECT shard_name, table_name, citus_table_type, shard_size FROM citus_shards OR part_mx_1220086 | part_mx | reference | 0 part_mx_1220086 | part_mx | reference | 0 part_mx_1220086 | part_mx | reference | 0 - researchers_mx_1220100 | researchers_mx | distributed | 0 - researchers_mx_1220100 | researchers_mx | distributed | 0 - researchers_mx_1220100 | researchers_mx | distributed | 0 - researchers_mx_1220100 | researchers_mx | distributed | 0 - researchers_mx_1220100 | researchers_mx | distributed | 0 - researchers_mx_1220100 | researchers_mx | distributed | 0 - researchers_mx_1220100 | researchers_mx | distributed | 0 - researchers_mx_1220101 | researchers_mx | distributed | 0 + researchers_mx_1220100 | researchers_mx | distributed | 8192 + researchers_mx_1220100 | researchers_mx | distributed | 8192 + researchers_mx_1220100 | researchers_mx | distributed | 8192 + researchers_mx_1220100 | researchers_mx | distributed | 8192 + researchers_mx_1220100 | researchers_mx | distributed | 8192 + researchers_mx_1220100 | researchers_mx | distributed | 8192 + researchers_mx_1220100 | researchers_mx | distributed | 8192 + researchers_mx_1220101 | researchers_mx | distributed | 8192 supplier_mx_1220087 | supplier_mx | reference | 0 supplier_mx_1220087 | supplier_mx | reference | 0 supplier_mx_1220087 | supplier_mx | reference | 0