You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hawq.apache.org by ml...@apache.org on 2015/12/25 06:39:09 UTC

[2/2] incubator-hawq git commit: HAWQ-273. Need re-fetch snapshot at planning stage because data locality and hdfs metadata cache will fetch pg_aoseg data

HAWQ-273. Need re-fetch snapshot at planning stage because data locality and hdfs metadata cache will fetch pg_aoseg data


Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/dd7a3bf0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/dd7a3bf0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/dd7a3bf0

Branch: refs/heads/master
Commit: dd7a3bf0277dbd9693a38d82bdf227dcc2b9121f
Parents: 10e2b18
Author: Ming LI <ml...@pivotal.io>
Authored: Wed Dec 23 18:28:29 2015 +0800
Committer: Ming LI <ml...@pivotal.io>
Committed: Fri Dec 25 13:37:13 2015 +0800

----------------------------------------------------------------------
 src/backend/commands/prepare.c | 6 +++---
 src/backend/tcop/postgres.c    | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/dd7a3bf0/src/backend/commands/prepare.c
----------------------------------------------------------------------
diff --git a/src/backend/commands/prepare.c b/src/backend/commands/prepare.c
index d3986c6..76c04e9 100644
--- a/src/backend/commands/prepare.c
+++ b/src/backend/commands/prepare.c
@@ -131,7 +131,7 @@ PrepareQuery(PrepareStmt *stmt, const char *queryString)
 	query_list_copy = copyObject(query_list); /* planner scribbles on query tree */
 	
 	/* Generate plans for queries.	Snapshot is already set. */
-	plan_list = pg_plan_queries(query_list, NULL, false, QRL_NONE);
+	plan_list = pg_plan_queries(query_list, NULL, true, QRL_NONE);
 	
 	/*
 	 * Save the results.  We don't have the query string for this PREPARE, but
@@ -202,7 +202,7 @@ ExecuteQuery(ExecuteStmt *stmt, const char *queryString,
 			query->intoClause = copyObject(stmt->into);
 		}
 		
-		stmt_list = pg_plan_queries(query_list, paramLI, false, QRL_ONCE);
+		stmt_list = pg_plan_queries(query_list, paramLI, true, QRL_ONCE);
 	}
 
 	/*
@@ -668,7 +668,7 @@ ExplainExecuteQuery(ExecuteStmt *execstmt, ExplainStmt *stmt, const char * query
 	
 	
 	query_list = copyObject(entry->query_list); /* planner scribbles on query tree */
-	stmt_list = pg_plan_queries(query_list, paramLI, false, QRL_ONCE);
+	stmt_list = pg_plan_queries(query_list, paramLI, true, QRL_ONCE);
 	
 	Assert(list_length(query_list) == list_length(stmt_list));
 

http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/dd7a3bf0/src/backend/tcop/postgres.c
----------------------------------------------------------------------
diff --git a/src/backend/tcop/postgres.c b/src/backend/tcop/postgres.c
index f6f0c54..d0c8e70 100644
--- a/src/backend/tcop/postgres.c
+++ b/src/backend/tcop/postgres.c
@@ -1645,7 +1645,7 @@ exec_simple_query(const char *query_string, const char *seqServerHost, int seqSe
 		querytree_list = pg_analyze_and_rewrite(parsetree, query_string,
 												NULL, 0);
 
-		plantree_list = pg_plan_queries(querytree_list, NULL, false, QRL_ONCE);
+		plantree_list = pg_plan_queries(querytree_list, NULL, true, QRL_ONCE);
 
 		/* Done with the snapshot used for parsing/planning */
 		ActiveSnapshot = NULL;