This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 440f60738af (cloud-merge) Fix create mv failed bacause expr is null
(#34010)
440f60738af is described below
commit 440f60738afba27e4393e74a3461d2bd02843a61
Author: Lightman <[email protected]>
AuthorDate: Thu Apr 25 10:33:13 2024 +0800
(cloud-merge) Fix create mv failed bacause expr is null (#34010)
---
fe/fe-core/src/main/java/org/apache/doris/alter/CloudRollupJobV2.java | 3 ++-
fe/fe-core/src/main/java/org/apache/doris/alter/RollupJobV2.java | 2 +-
.../src/main/java/org/apache/doris/cloud/CacheHotspotManagerUtils.java | 2 +-
3 files changed, 4 insertions(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/alter/CloudRollupJobV2.java
b/fe/fe-core/src/main/java/org/apache/doris/alter/CloudRollupJobV2.java
index 51c4abde769..1474de4d22f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/CloudRollupJobV2.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/CloudRollupJobV2.java
@@ -55,7 +55,7 @@ import java.util.Map;
public class CloudRollupJobV2 extends RollupJobV2 {
private static final Logger LOG =
LogManager.getLogger(CloudRollupJobV2.class);
- public static AlterJobV2 buildCloudRollupJobV2(RollupJobV2 job) throws
IllegalAccessException {
+ public static AlterJobV2 buildCloudRollupJobV2(RollupJobV2 job) throws
IllegalAccessException, AnalysisException {
CloudRollupJobV2 ret = new CloudRollupJobV2();
List<Field> allFields = new ArrayList<>();
Class tmpClass = RollupJobV2.class;
@@ -70,6 +70,7 @@ public class CloudRollupJobV2 extends RollupJobV2 {
field.set(ret, field.get(job));
}
}
+ ret.initAnalyzer();
return ret;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJobV2.java
b/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJobV2.java
index 60c02b6b525..ec0868637e7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJobV2.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJobV2.java
@@ -183,7 +183,7 @@ public class RollupJobV2 extends AlterJobV2 implements
GsonPostProcessable {
this.storageFormat = storageFormat;
}
- private void initAnalyzer() throws AnalysisException {
+ protected void initAnalyzer() throws AnalysisException {
ConnectContext connectContext = new ConnectContext();
Database db;
try {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManagerUtils.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManagerUtils.java
index 796b2f99560..e3fff32035d 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManagerUtils.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManagerUtils.java
@@ -48,7 +48,7 @@ public class CacheHotspotManagerUtils {
FeConstants.INTERNAL_DB_NAME,
FeConstants.INTERNAL_FILE_CACHE_HOTSPOT_TABLE_NAME);
// TODO(yuejing): 如何加字段
private static final String CREATE_CACHE_TABLE =
- "create table " + TABLE_NAME + " IF NOT EXISTS (\n"
+ "create table " + TABLE_NAME + " (\n"
+ " cluster_id varchar(65530),\n"
+ " backend_id bigint,\n"
+ " table_id bigint,\n"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
