diff --git a/src/backend/distributed/sql/udfs/any_value/9.1-1.sql b/src/backend/distributed/sql/udfs/any_value/9.1-1.sql
index 7eb9fdb25..053474968 100644
--- a/src/backend/distributed/sql/udfs/any_value/9.1-1.sql
+++ b/src/backend/distributed/sql/udfs/any_value/9.1-1.sql
@@ -3,6 +3,7 @@ RETURNS anyelement AS $$
         SELECT CASE WHEN $1 IS NULL THEN $2 ELSE $1 END;
 $$ LANGUAGE SQL STABLE;
 
+DO $$ BEGIN
 CREATE AGGREGATE pg_catalog.any_value (
         sfunc       = pg_catalog.any_value_agg,
         combinefunc = pg_catalog.any_value_agg,
@@ -11,4 +12,6 @@ CREATE AGGREGATE pg_catalog.any_value (
 );
 COMMENT ON AGGREGATE pg_catalog.any_value(anyelement) IS
     'Returns the value of any row in the group. It is mostly useful when you know there will be only 1 element.';
-
+EXCEPTION
+    WHEN duplicate_function THEN NULL;
+END $$;
diff --git a/src/backend/distributed/sql/udfs/any_value/latest.sql b/src/backend/distributed/sql/udfs/any_value/latest.sql
index 7eb9fdb25..053474968 100644
--- a/src/backend/distributed/sql/udfs/any_value/latest.sql
+++ b/src/backend/distributed/sql/udfs/any_value/latest.sql
@@ -3,6 +3,7 @@ RETURNS anyelement AS $$
         SELECT CASE WHEN $1 IS NULL THEN $2 ELSE $1 END;
 $$ LANGUAGE SQL STABLE;
 
+DO $$ BEGIN
 CREATE AGGREGATE pg_catalog.any_value (
         sfunc       = pg_catalog.any_value_agg,
         combinefunc = pg_catalog.any_value_agg,
@@ -11,4 +12,6 @@ CREATE AGGREGATE pg_catalog.any_value (
 );
 COMMENT ON AGGREGATE pg_catalog.any_value(anyelement) IS
     'Returns the value of any row in the group. It is mostly useful when you know there will be only 1 element.';
-
+EXCEPTION
+    WHEN duplicate_function THEN NULL;
+END $$;