This commit is contained in:
@ -325,6 +325,12 @@ public class MTMVPartitionUtil {
|
||||
for (String relatedPartitionName : relatedPartitionNames) {
|
||||
MTMVSnapshotIf relatedPartitionCurrentSnapshot = relatedTable
|
||||
.getPartitionSnapshot(relatedPartitionName, context, Optional.empty());
|
||||
if (LOG.isDebugEnabled()) {
|
||||
LOG.debug(String.format("isSyncWithPartitions mvName is %s\n, mtmvPartitionName is %s\n, "
|
||||
+ "mtmv refreshSnapshot is %s\n, relatedPartitionName is %s\n, "
|
||||
+ "relatedPartitionCurrentSnapshot is %s", mtmv.getName(), mtmvPartitionName,
|
||||
mtmv.getRefreshSnapshot(), relatedPartitionName, relatedPartitionCurrentSnapshot));
|
||||
}
|
||||
if (!mtmv.getRefreshSnapshot()
|
||||
.equalsWithRelatedPartition(mtmvPartitionName, relatedPartitionName,
|
||||
relatedPartitionCurrentSnapshot)) {
|
||||
|
||||
@ -495,6 +495,17 @@ public abstract class AbstractMaterializedViewRule implements ExplorationRuleFac
|
||||
// if mv can not offer any partition for query, query rewrite bail out
|
||||
return null;
|
||||
}
|
||||
if (LOG.isDebugEnabled()) {
|
||||
LOG.debug(String.format("calcInvalidPartitions mv name is %s,\n mvValidBaseTablePartitionNameSet is %s,\n "
|
||||
+ "mvValidHasDataRelatedBaseTableNameSet is %s,\n"
|
||||
+ "queryUsedBaseTablePartitionNameSet is %s,\n "
|
||||
+ "partitionMapping is %s \n, sql hash is %s",
|
||||
materializationContext.generateMaterializationIdentifier(),
|
||||
mvValidBaseTablePartitionNameSet,
|
||||
mvValidHasDataRelatedBaseTableNameSet,
|
||||
queryUsedBaseTablePartitionNameSet,
|
||||
partitionMapping, cascadesContext.getConnectContext().getSqlHash()));
|
||||
}
|
||||
// Check when mv partition relates base table partition data change or delete partition
|
||||
Set<String> rewrittenPlanUsePartitionNameSet = new HashSet<>();
|
||||
List<Object> mvOlapScanList = rewrittenPlan.collectToList(node ->
|
||||
|
||||
Reference in New Issue
Block a user