This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new f2e4b748bfc branch-3.0: [fix](mtmv)After failure, one should quickly
return to avoid repeated failures #44174 (#44203)
f2e4b748bfc is described below
commit f2e4b748bfc21fb93b2474fe9772cd84bb81ed8b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Nov 19 20:26:09 2024 +0800
branch-3.0: [fix](mtmv)After failure, one should quickly return to avoid
repeated failures #44174 (#44203)
Cherry-picked from #44174
Co-authored-by: zhangdong <[email protected]>
---
.../src/main/java/org/apache/doris/mtmv/MTMVRewriteUtil.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRewriteUtil.java
b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRewriteUtil.java
index 5e17673a068..7b7d743a36b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRewriteUtil.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRewriteUtil.java
@@ -64,10 +64,16 @@ public class MTMVRewriteUtil {
res.add(partition);
continue;
}
- try {
- if (refreshContext == null) {
+ if (refreshContext == null) {
+ try {
refreshContext = MTMVRefreshContext.buildContext(mtmv);
+ } catch (AnalysisException e) {
+ LOG.warn("buildContext failed", e);
+ // After failure, one should quickly return to avoid
repeated failures
+ return res;
}
+ }
+ try {
if (MTMVPartitionUtil.isMTMVPartitionSync(refreshContext,
partition.getName(),
mtmvRelation.getBaseTablesOneLevel(),
Sets.newHashSet())) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
