This is an automated email from the ASF dual-hosted git repository.
morningman 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 fb622800aad [fix](mtmv)Compatible old mtmv metadata (#26193)
fb622800aad is described below
commit fb622800aad85227b3d01b29cf472f072e34ef1e
Author: zhangdong <[email protected]>
AuthorDate: Thu Nov 2 12:04:04 2023 +0800
[fix](mtmv)Compatible old mtmv metadata (#26193)
make sure user can upgrade from v2.0 to master
---
.../main/java/org/apache/doris/catalog/MTMV.java | 32 ++++++++++++++++++++++
.../main/java/org/apache/doris/catalog/Table.java | 2 ++
2 files changed, 34 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java
new file mode 100644
index 00000000000..e463c3dfe70
--- /dev/null
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java
@@ -0,0 +1,32 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package org.apache.doris.catalog;
+
+import org.apache.doris.common.io.Text;
+
+import java.io.DataInput;
+import java.io.IOException;
+
+public class MTMV extends OlapTable {
+
+ @Override
+ public void readFields(DataInput in) throws IOException {
+ super.readFields(in);
+ Text.readString(in);
+ }
+}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
index 65d8cc89c91..30b0c9da4b2 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
@@ -363,6 +363,8 @@ public abstract class Table extends MetaObject implements
Writable, TableIf {
TableType type = TableType.valueOf(Text.readString(in));
if (type == TableType.OLAP) {
table = new OlapTable();
+ } else if (type == TableType.MATERIALIZED_VIEW) {
+ table = new MTMV();
} else if (type == TableType.ODBC) {
table = new OdbcTable();
} else if (type == TableType.MYSQL) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
