diff --git a/src/common/backend/catalog/builtin_funcs.ini b/src/common/backend/catalog/builtin_funcs.ini
index 4f5222007efbb980689189d98bf6360f3f525408..3b795da7f140ae03f20d0bac6f838e39a793f593 100644
--- a/src/common/backend/catalog/builtin_funcs.ini
+++ b/src/common/backend/catalog/builtin_funcs.ini
@@ -13044,7 +13044,7 @@ AddFuncGroup(
     ),
     AddFuncGroup(
         "gs_get_recv_locations", 1, 
-        AddBuiltinFunc(_0(2872), _1("gs_get_recv_locations"), _2(0), _3(false), _4(true), _5(gs_get_recv_locations), _6(2249), _7(PG_CATALOG_NAMESPACE), _8(BOOTSTRAP_SUPERUSERID), _9(INTERNALlanguageId), _10(1), _11(10), _12(0), _13(0), _14(false), _15(false), _16(false), _17(false), _18('v'), _19(0), _20(0), _21(4, 25, 25, 25, 25), _22(4, 'o', 'o', 'o', 'o'), _23(4, "received_lsn", "write_lsn", "flush_lsn", "replay_lsn"), _24(NULL), _25("gs_get_recv_locations"), _26(NULL), _27(NULL), _28(NULL), _29(0), _30(false), _31(NULL), _32(false), _33("statistics: information about WAL locations"), _34('f'), _35(NULL),  _36(0), _37(false), _38(NULL), _39(NULL), _40(0))
+        AddBuiltinFunc(_0(2872), _1("gs_get_recv_locations"), _2(0), _3(false), _4(true), _5(gs_get_recv_locations), _6(2249), _7(PG_CATALOG_NAMESPACE), _8(BOOTSTRAP_SUPERUSERID), _9(INTERNALlanguageId), _10(1), _11(10), _12(0), _13(0), _14(false), _15(false), _16(false), _17(false), _18('v'), _19(0), _20(0), _21(4, 25, 25, 25, 25), _22(4, 'o', 'o', 'o', 'o'), _23(4, "received_lsn", "write_lsn", "flush_lsn", "replay_lsn"), _24(NULL), _25("gs_get_recv_locations"), _26(NULL), _27(NULL), _28(NULL), _29(0), _30(false), _31(false), _32(false), _33("statistics: information about currently wal locations"), _34('f'), _35(NULL),  _36(0), _37(false), _38(NULL), _39(NULL), _40(0))
     ),
     AddFuncGroup(
         "gs_get_hba_conf", 1, 
diff --git a/src/common/backend/utils/init/globals.cpp b/src/common/backend/utils/init/globals.cpp
index ccb12587ff0ed5dab40612f1b79b1476ad26fa1c..08248b6ef7bf2061c22613bed73bbd2807c6bf2e 100644
--- a/src/common/backend/utils/init/globals.cpp
+++ b/src/common/backend/utils/init/globals.cpp
@@ -76,12 +76,13 @@ bool will_shutdown = false;
  *
  ********************************************/
 
-const uint32 GRAND_VERSION_NUM = 92950;
+const uint32 GRAND_VERSION_NUM = 92951;
 
 /********************************************
  * 2.VERSION NUM FOR EACH FEATURE
  *   Please write indescending order.
  ********************************************/
+const uint32 FLUSH_LSN_FUN_VERSION_NUM = 92951;
 const uint32 PUBLICATION_DDL_AT_VERSION_NUM = 92949;
 const uint32 MINMAXEXPR_CMPTYPE_VERSION_NUM = 92948;
 const uint32 PARTITION_NAME_VERSION_NUM = 92947;
diff --git a/src/include/catalog/upgrade_sql/rollback_catalog_maindb/rollback-post_catalog_maindb_92_951.sql b/src/include/catalog/upgrade_sql/rollback_catalog_maindb/rollback-post_catalog_maindb_92_951.sql
new file mode 100644
index 0000000000000000000000000000000000000000..bccda40276951eaf041227c8c321166fbdd7460a
--- /dev/null
+++ b/src/include/catalog/upgrade_sql/rollback_catalog_maindb/rollback-post_catalog_maindb_92_951.sql
@@ -0,0 +1,11 @@
+DROP FUNCTION IF EXISTS pg_catalog.gs_get_recv_locations() CASCADE;
+
+SET LOCAL inplace_upgrade_next_system_object_oids=IUO_PROC, 2872;
+
+CREATE FUNCTION pg_catalog.gs_get_recv_locations(
+ out received_lsn text,
+ out write_lsn text,
+ out flush_lsn text,
+ out replay_lsn text)
+RETURNS record LANGUAGE INTERNAL VOLATILE STRICT as 'gs_get_recv_locations';
+comment on function pg_catalog.gs_get_recv_locations() is 'statistics: information about currently wal locations';
\ No newline at end of file
diff --git a/src/include/catalog/upgrade_sql/rollback_catalog_otherdb/rollback-post_catalog_otherdb_92_951.sql b/src/include/catalog/upgrade_sql/rollback_catalog_otherdb/rollback-post_catalog_otherdb_92_951.sql
new file mode 100644
index 0000000000000000000000000000000000000000..bccda40276951eaf041227c8c321166fbdd7460a
--- /dev/null
+++ b/src/include/catalog/upgrade_sql/rollback_catalog_otherdb/rollback-post_catalog_otherdb_92_951.sql
@@ -0,0 +1,11 @@
+DROP FUNCTION IF EXISTS pg_catalog.gs_get_recv_locations() CASCADE;
+
+SET LOCAL inplace_upgrade_next_system_object_oids=IUO_PROC, 2872;
+
+CREATE FUNCTION pg_catalog.gs_get_recv_locations(
+ out received_lsn text,
+ out write_lsn text,
+ out flush_lsn text,
+ out replay_lsn text)
+RETURNS record LANGUAGE INTERNAL VOLATILE STRICT as 'gs_get_recv_locations';
+comment on function pg_catalog.gs_get_recv_locations() is 'statistics: information about currently wal locations';
\ No newline at end of file
diff --git a/src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_951.sql b/src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_951.sql
new file mode 100644
index 0000000000000000000000000000000000000000..b748e70a3475f8a98331b640eb36a37213946204
--- /dev/null
+++ b/src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_951.sql
@@ -0,0 +1,11 @@
+DROP FUNCTION IF EXISTS pg_catalog.gs_get_recv_locations() CASCADE;
+
+SET LOCAL inplace_upgrade_next_system_object_oids=IUO_PROC, 2872;
+
+CREATE FUNCTION pg_catalog.gs_get_recv_locations(
+ out received_lsn text,
+ out write_lsn text,
+ out flush_lsn text,
+ out replay_lsn text)
+RETURNS  SETOF record LANGUAGE INTERNAL VOLATILE NOT SHIPPABLE ROWS 10 as 'gs_get_recv_locations';
+comment on function pg_catalog.gs_get_recv_locations() is 'statistics: information about currently wal locations';
\ No newline at end of file
diff --git a/src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_951.sql b/src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_951.sql
new file mode 100644
index 0000000000000000000000000000000000000000..b748e70a3475f8a98331b640eb36a37213946204
--- /dev/null
+++ b/src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_951.sql
@@ -0,0 +1,11 @@
+DROP FUNCTION IF EXISTS pg_catalog.gs_get_recv_locations() CASCADE;
+
+SET LOCAL inplace_upgrade_next_system_object_oids=IUO_PROC, 2872;
+
+CREATE FUNCTION pg_catalog.gs_get_recv_locations(
+ out received_lsn text,
+ out write_lsn text,
+ out flush_lsn text,
+ out replay_lsn text)
+RETURNS  SETOF record LANGUAGE INTERNAL VOLATILE NOT SHIPPABLE ROWS 10 as 'gs_get_recv_locations';
+comment on function pg_catalog.gs_get_recv_locations() is 'statistics: information about currently wal locations';
\ No newline at end of file