fix 3

apache · Jan 7, 2025 · 95df08a · 95df08a
1 parent f0439c7
commit 95df08a
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalTable.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalTable.java
@@ -157,7 +157,6 @@ public class HMSExternalTable extends ExternalTable implements MTMVRelatedTableI
 
     private DLAType dlaType = DLAType.UNKNOWN;
 
-    @SerializedName(value = "dlaTable")
     private HMSDlaTable dlaTable;
 
     // record the event update time when enable hms event listener
@@ -201,7 +200,7 @@ protected synchronized void makeSureInitialized() {
                     dlaType = DLAType.HUDI;
                 } else if (supportedHiveTable()) {
                     dlaType = DLAType.HIVE;
-                    dlaTable = new HiveExternalTable(this);
+                    dlaTable = new HiveDlaTable(this);
                 } else {
                     // Should not reach here. Because `supportedHiveTable` will throw exception if not return true.
                     throw new NotSupportedException("Unsupported dlaType for table: " + getNameWithFullQualifiers());
@@ -308,6 +307,7 @@ public List<Column> getPartitionColumns() {
 
     @Override
     public List<Column> getPartitionColumns(Optional<MvccSnapshot> snapshot) {
+        makeSureInitialized();
         return dlaTable.getPartitionColumns(snapshot);
     }
 
@@ -802,6 +802,7 @@ public Set<String> getDistributionColumnNames() {
 
     @Override
     public PartitionType getPartitionType(Optional<MvccSnapshot> snapshot) {
+        makeSureInitialized();
         return dlaTable.getPartitionType(snapshot);
     }
 
@@ -811,6 +812,7 @@ public PartitionType getPartitionType() {
 
     @Override
     public Set<String> getPartitionColumnNames(Optional<MvccSnapshot> snapshot) throws DdlException {
+        makeSureInitialized();
         return dlaTable.getPartitionColumnNames(snapshot);
     }
 
@@ -822,23 +824,27 @@ public Set<String> getPartitionColumnNames() {
     @Override
     public Map<String, PartitionItem> getAndCopyPartitionItems(Optional<MvccSnapshot> snapshot)
             throws AnalysisException {
+        makeSureInitialized();
         return dlaTable.getAndCopyPartitionItems(snapshot);
     }
 
     @Override
     public MTMVSnapshotIf getPartitionSnapshot(String partitionName, MTMVRefreshContext context,
             Optional<MvccSnapshot> snapshot) throws AnalysisException {
+        makeSureInitialized();
         return dlaTable.getPartitionSnapshot(partitionName, context, snapshot);
     }
 
     @Override
     public MTMVSnapshotIf getTableSnapshot(MTMVRefreshContext context, Optional<MvccSnapshot> snapshot)
             throws AnalysisException {
+        makeSureInitialized();
         return dlaTable.getTableSnapshot(context, snapshot);
     }
 
     @Override
     public boolean isPartitionColumnAllowNull() {
+        makeSureInitialized();
         return dlaTable.isPartitionColumnAllowNull();
     }
 
@@ -974,6 +980,7 @@ public boolean isPartitionedTable() {
 
     @Override
     public void beforeMTMVRefresh(MTMV mtmv) throws DdlException {
+        makeSureInitialized();
         dlaTable.beforeMTMVRefresh(mtmv);
     }
 

diff --git a/...is/datasource/hive/HiveExternalTable.java → ...e/doris/datasource/hive/HiveDlaTable.java b/...is/datasource/hive/HiveExternalTable.java → ...e/doris/datasource/hive/HiveDlaTable.java
@@ -36,9 +36,9 @@
 import java.util.Optional;
 import java.util.Set;
 
-public class HiveExternalTable extends HMSDlaTable {
+public class HiveDlaTable extends HMSDlaTable {
 
-    public HiveExternalTable(HMSExternalTable table) {
+    public HiveDlaTable(HMSExternalTable table) {
         super(table);
     }