diff --git a/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/10.2-1.sql b/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/10.2-1.sql
index ecefea7f4..c808c9ac3 100644
--- a/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/10.2-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/10.2-1.sql
@@ -9,6 +9,7 @@ BEGIN
         objid IN (SELECT oid FROM pg_proc WHERE proname = 'array_cat_agg') AND 
         refobjid IN (select oid from pg_extension where extname = 'citus');
     DROP AGGREGATE IF EXISTS array_cat_agg(anyarray);
+    DROP AGGREGATE IF EXISTS array_cat_agg(anycompatiblearray);
     --
     -- Drop existing backup tables
     --
diff --git a/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql b/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql
index ecefea7f4..c808c9ac3 100644
--- a/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql
+++ b/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql
@@ -9,6 +9,7 @@ BEGIN
         objid IN (SELECT oid FROM pg_proc WHERE proname = 'array_cat_agg') AND 
         refobjid IN (select oid from pg_extension where extname = 'citus');
     DROP AGGREGATE IF EXISTS array_cat_agg(anyarray);
+    DROP AGGREGATE IF EXISTS array_cat_agg(anycompatiblearray);
     --
     -- Drop existing backup tables
     --
diff --git a/src/test/regress/upgrade/utils.py b/src/test/regress/upgrade/utils.py
index 9c1961d8b..f09cd74e4 100644
--- a/src/test/regress/upgrade/utils.py
+++ b/src/test/regress/upgrade/utils.py
@@ -4,6 +4,7 @@ from config import USER
 
 
 def psql(pg_path, port, command):
+    print("RUNNING ", command)
     return subprocess.check_output([
         os.path.join(pg_path, 'psql'),
         '-U', USER,