[iotdb] branch xingtanzjr/query_retry updated: add schema partition fetch logic for each retry

[xingtanzjr]

This is an automated email from the ASF dual-hosted git repository.

xingtanzjr pushed a commit to branch xingtanzjr/query_retry
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/xingtanzjr/query_retry by this 
push:
     new b92f426d84 add schema partition fetch logic for each retry
b92f426d84 is described below

commit b92f426d84c84233738b61e380c7d719feb14d98
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Thu Jul 14 12:16:49 2022 +0800

    add schema partition fetch logic for each retry
---
 .../main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
index 3148c41769..5921013abb 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
@@ -1223,7 +1223,8 @@ public class AnalyzeVisitor extends 
StatementVisitor<Analysis, MPPQueryContext>
       SchemaFetchStatement schemaFetchStatement, MPPQueryContext context) {
     Analysis analysis = new Analysis();
     analysis.setStatement(schemaFetchStatement);
-    analysis.setSchemaPartitionInfo(schemaFetchStatement.getSchemaPartition());
+    analysis.setSchemaPartitionInfo(
+        
partitionFetcher.getSchemaPartition(schemaFetchStatement.getPatternTree()));
     return analysis;
   }