diff --git a/src/gausskernel/process/postmaster/pgarch.cpp b/src/gausskernel/process/postmaster/pgarch.cpp index 35426e16..57c4c4f1 100644 --- a/src/gausskernel/process/postmaster/pgarch.cpp +++ b/src/gausskernel/process/postmaster/pgarch.cpp @@ -439,7 +439,7 @@ static void pgarch_MainLoop(void) if (t_thrd.arch.pitr_task_last_lsn == InvalidXLogRecPtr) { initLastTaskLsn(); } - uint32 size; + uint32 size = 0; if (obs_archive_slot->archive_obs->media_type == ARCHIVE_OBS) { size = OBS_XLOG_SLICE_BLOCK_SIZE; } else if (obs_archive_slot->archive_obs->media_type == ARCHIVE_NAS) { diff --git a/src/include/catalog/upgrade_sql/rollback_catalog_maindb/rollback_catalog_maindb_92_300.sql b/src/include/catalog/upgrade_sql/rollback_catalog_maindb/rollback_catalog_maindb_92_300.sql index be358abd..a77908e1 100644 --- a/src/include/catalog/upgrade_sql/rollback_catalog_maindb/rollback_catalog_maindb_92_300.sql +++ b/src/include/catalog/upgrade_sql/rollback_catalog_maindb/rollback_catalog_maindb_92_300.sql @@ -1 +1,2 @@ -DROP VIEW IF EXISTS pg_catalog.gs_archive_status; \ No newline at end of file +DROP VIEW IF EXISTS pg_catalog.gs_archive_status; +DROP FUNCTION IF EXISTS pg_catalog.gs_get_archive_status(); diff --git a/src/include/catalog/upgrade_sql/rollback_catalog_otherdb/rollback_catalog_otherdb_92_300.sql b/src/include/catalog/upgrade_sql/rollback_catalog_otherdb/rollback_catalog_otherdb_92_300.sql index be358abd..a77908e1 100644 --- a/src/include/catalog/upgrade_sql/rollback_catalog_otherdb/rollback_catalog_otherdb_92_300.sql +++ b/src/include/catalog/upgrade_sql/rollback_catalog_otherdb/rollback_catalog_otherdb_92_300.sql @@ -1 +1,2 @@ -DROP VIEW IF EXISTS pg_catalog.gs_archive_status; \ No newline at end of file +DROP VIEW IF EXISTS pg_catalog.gs_archive_status; +DROP FUNCTION IF EXISTS pg_catalog.gs_get_archive_status(); diff --git a/src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_300.sql b/src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_300.sql index a21d7c85..b30ab1cd 100644 --- a/src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_300.sql +++ b/src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_300.sql @@ -1 +1,3 @@ -CREATE OR REPLACE VIEW pg_catalog.gs_archive_status AS SELECT * FROM gs_get_archive_status(); \ No newline at end of file +CREATE FUNCTION pg_catalog.gs_get_archive_status(OUT archive_standby TEXT, OUT last_task_lsn TEXT, OUT "last_arch_time" TIMESTAMPTZ, OUT archive_path TEXT) +RETURNS SETOF RECORD LANGUAGE INTERNAL STABLE ROWS 1 STRICT as 'gs_get_archive_status'; +CREATE OR REPLACE VIEW pg_catalog.gs_archive_status AS SELECT * FROM gs_get_archive_status(); diff --git a/src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_300.sql b/src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_300.sql index a21d7c85..b30ab1cd 100644 --- a/src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_300.sql +++ b/src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_300.sql @@ -1 +1,3 @@ -CREATE OR REPLACE VIEW pg_catalog.gs_archive_status AS SELECT * FROM gs_get_archive_status(); \ No newline at end of file +CREATE FUNCTION pg_catalog.gs_get_archive_status(OUT archive_standby TEXT, OUT last_task_lsn TEXT, OUT "last_arch_time" TIMESTAMPTZ, OUT archive_path TEXT) +RETURNS SETOF RECORD LANGUAGE INTERNAL STABLE ROWS 1 STRICT as 'gs_get_archive_status'; +CREATE OR REPLACE VIEW pg_catalog.gs_archive_status AS SELECT * FROM gs_get_archive_status();