| schema | name | column | data type |
|---|---|---|---|
| pg_catalog | svl_restore_alter_table_progress | message | char(350) |
| pg_catalog | svl_restore_alter_table_progress | progress | varchar(41) |
| pg_catalog | svl_restore_alter_table_progress | tbl | int4 |
((SELECT conversion_completed_tables.tbl,
CAST(CAST(round(conversion_completed_tables.progress, 2) AS text) || CAST('%' AS text) AS varchar) AS progress,
'Restored to distkey successfully.' AS message
FROM (SELECT stl_xrestore_alter_distkey.pid,
stl_xrestore_alter_distkey.tbl,
100.0 AS progress
FROM stl_xrestore_alter_distkey
WHERE stl_xrestore_alter_distkey.message ~~ CAST('%Completed%' AS text)) AS conversion_completed_tables
UNION
SELECT aborted_tbl.tbl,
'ABORTED' AS progress,
aborted_tbl.message
FROM (SELECT DISTINCT stl_xrestore_alter_distkey.tbl,
stl_xrestore_alter_distkey.message
FROM stl_xrestore_alter_distkey
WHERE stl_xrestore_alter_distkey.message ~~ CAST('%Abort:%' AS text)) AS aborted_tbl)
UNION
SELECT tbl_in_progress.tbl,
CAST(CAST(round(tbl_in_progress.progress, 2) AS text) || CAST('%' AS text) AS varchar) AS progress,
'Alter diststyle in progress.' AS message
FROM (SELECT alt_dist.tbl,
CASE
WHEN alt_dist.src_rows = 0
THEN 100.0
ELSE CAST(100 * alt_dist.dest_rows AS numeric) / (CAST(alt_dist.src_rows AS numeric) * 1.0)
END AS progress
FROM (SELECT alter_dist.tbl,
max(alter_dist.eventtime) AS last_eventtime
FROM (SELECT stl2.tbl,
stl2.pid
FROM (SELECT stl.tbl,
max(stl.event_time) AS last_eventtime
FROM stl_xrestore_alter_distkey AS stl
GROUP BY stl.tbl) AS table_max_eventtime
INNER JOIN stl_xrestore_alter_distkey AS stl2 ON stl2.tbl = table_max_eventtime.tbl
AND stl2.event_time = table_max_eventtime.last_eventtime
INNER JOIN stv_xrestore_alter_queue_state AS stv ON table_max_eventtime.tbl = stv.tbl
AND table_max_eventtime.tbl = stl2.tbl
WHERE stv.status ~~ CAST('%Applying%' AS text)
AND stl2.message !~ similar_escape(CAST('%(Completed|Abort:)%' AS text),
CAST(NULL AS text))) AS auto_worker
INNER JOIN stl_alter_dist_sort AS alter_dist ON auto_worker.tbl = alter_dist.tbl
AND auto_worker.pid = alter_dist.pid
WHERE NOT alter_dist.tbl IN (SELECT conversion_completed_tables.tbl
FROM (SELECT stl_xrestore_alter_distkey.pid,
stl_xrestore_alter_distkey.tbl,
100.0 AS progress
FROM stl_xrestore_alter_distkey
WHERE stl_xrestore_alter_distkey.message ~~ CAST('%Completed%' AS text)) AS conversion_completed_tables)
AND alter_dist.event !~~ CAST('%Start%' AS text)
AND alter_dist.is_autoworker_altered = 1
GROUP BY alter_dist.tbl) AS last_event
INNER JOIN stl_alter_dist_sort AS alt_dist ON last_event.last_eventtime = alt_dist.eventtime
AND last_event.tbl = alt_dist.tbl) AS tbl_in_progress)
UNION
SELECT tbl_pending.tbl,
CAST(CAST(round(tbl_pending.progress, 2) AS text) || CAST('%' AS text) AS varchar) AS progress,
'Table waiting for alter diststyle conversion.' AS message
FROM (SELECT all_tbl.tbl,
0.0 AS progress
FROM stl_xrestore_cluster_level_distkey_tables AS all_tbl
WHERE (all_tbl.action ~~ CAST('%DistkeyTableImportedAsDistEven%' AS text)
OR all_tbl.action ~~ CAST('%DistevenTableMarkedForRedistribution%' AS text))
AND NOT all_tbl.tbl IN ((SELECT conversion_completed_tables.tbl
FROM (SELECT stl_xrestore_alter_distkey.pid,
stl_xrestore_alter_distkey.tbl,
100.0 AS progress
FROM stl_xrestore_alter_distkey
WHERE stl_xrestore_alter_distkey.message ~~ CAST('%Completed%' AS text)) AS conversion_completed_tables
UNION
SELECT tbl_in_progress.tbl
FROM (SELECT alt_dist.tbl,
CASE
WHEN alt_dist.src_rows = 0
THEN 100.0
ELSE CAST(100 * alt_dist.dest_rows AS numeric) / (CAST(alt_dist.src_rows AS numeric) * 1.0)
END AS progress
FROM (SELECT alter_dist.tbl,
max(alter_dist.eventtime) AS last_eventtime
FROM (SELECT stl2.tbl,
stl2.pid
FROM (SELECT stl.tbl,
max(stl.event_time) AS last_eventtime
FROM stl_xrestore_alter_distkey AS stl
GROUP BY stl.tbl) AS table_max_eventtime
INNER JOIN stl_xrestore_alter_distkey AS stl2 ON stl2.tbl = table_max_eventtime.tbl
AND stl2.event_time = table_max_eventtime.last_eventtime
INNER JOIN stv_xrestore_alter_queue_state AS stv ON table_max_eventtime.tbl = stv.tbl
AND table_max_eventtime.tbl = stl2.tbl
WHERE stv.status ~~ CAST('%Applying%' AS text)
AND stl2.message !~ similar_escape(CAST('%(Completed|Abort:)%' AS text),
CAST(NULL AS text))) AS auto_worker
INNER JOIN stl_alter_dist_sort AS alter_dist ON auto_worker.tbl = alter_dist.tbl
AND auto_worker.pid = alter_dist.pid
WHERE NOT alter_dist.tbl IN (SELECT conversion_completed_tables.tbl
FROM (SELECT stl_xrestore_alter_distkey.pid,
stl_xrestore_alter_distkey.tbl,
100.0 AS progress
FROM stl_xrestore_alter_distkey
WHERE stl_xrestore_alter_distkey.message ~~ CAST('%Completed%' AS text)) AS conversion_completed_tables)
AND alter_dist.event !~~ CAST('%Start%' AS text)
AND alter_dist.is_autoworker_altered = 1
GROUP BY alter_dist.tbl) AS last_event
INNER JOIN stl_alter_dist_sort AS alt_dist ON last_event.last_eventtime = alt_dist.eventtime
AND last_event.tbl = alt_dist.tbl) AS tbl_in_progress)
UNION
SELECT aborted_tbl.tbl
FROM (SELECT DISTINCT stl_xrestore_alter_distkey.tbl,
stl_xrestore_alter_distkey.message
FROM stl_xrestore_alter_distkey
WHERE stl_xrestore_alter_distkey.message ~~ CAST('%Abort:%' AS text)) AS aborted_tbl)) AS tbl_pending Home 3D Друк Blog Bring-Up Times Consultancy Cross-Region Benchmarks Email Forums IRC Mailing Lists Reddit Redshift Price Tracker Redshift Version Tracker Redshift Workbench System Table Tracker The Known Universe Twitter White Papers