HAWQ-1417. Fixed crash when ANALYZE after COPY because of invalid resource owner

Author: liming01

src/backend/commands/analyze.c

@@ -308,6 +308,7 @@ void analyzeStmt(VacuumStmt *stmt, List *relids, int preferred_seg_num)
 	ListCell				*le1 = NULL;
 	int 					successCount = 0, failCount = 0;
 	StringInfoData 			failNames;
+	ResourceOwner owner, oldOwner;
 
 	/**
 	 * Ensure that an ANALYZE is requested.
@@ -476,6 +477,13 @@ void analyzeStmt(VacuumStmt *stmt, List *relids, int preferred_seg_num)
 		MemoryContextSwitchTo(analyzeStatementContext);
 	}
 
+	/**
+	 * Create a resource owner to keep track of our resources even not in trasaction block
+	 */
+	owner = ResourceOwnerCreate(CurrentResourceOwner, "analyzeStmt");
+	oldOwner = CurrentResourceOwner;
+	CurrentResourceOwner = owner;
+
 	/**
 	 *  we use preferred_seg_num as default and
 	 *  compute target_seg_num based on data size and distributed type
@@ -773,6 +781,12 @@ void analyzeStmt(VacuumStmt *stmt, List *relids, int preferred_seg_num)
 		resource = NULL;
 		UnsetActiveQueryResource();
 		SetActiveQueryResource(savedResource);
+		
+		ResourceOwnerRelease(owner,
+				RESOURCE_RELEASE_BEFORE_LOCKS,
+				false, true);
+		CurrentResourceOwner = oldOwner;
+		ResourceOwnerDelete(owner);
 
 		/* Carry on with error handling. */
 		PG_RE_THROW();
@@ -787,6 +801,12 @@ void analyzeStmt(VacuumStmt *stmt, List *relids, int preferred_seg_num)
 	UnsetActiveQueryResource();
 	SetActiveQueryResource(savedResource);
 
+	ResourceOwnerRelease(owner,
+            RESOURCE_RELEASE_BEFORE_LOCKS,
+            false, true);
+	CurrentResourceOwner = oldOwner;
+	ResourceOwnerDelete(owner);
+
 	if (bUseOwnXacts)
 	{
 		/**