Skip to content

Commit e0f5fee

Browse files
committed
fix
1 parent b1f8e18 commit e0f5fee

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveEngineCache.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -100,15 +100,15 @@ public EngineSnapshot getSnapshot(ExternalTable table, Optional<MvccSnapshot> sn
100100
return new HiveSnapshotMeta(hmsTable.getName(), hmsTable.getLastDdlTime());
101101
}
102102
HiveMetaStoreCache.HivePartitionValues partitionValues = hmsTable.getHivePartitionValues(snapshot);
103-
List<HivePartition> partitions = metaStoreCache.getAllPartitionsWithCache(
103+
List<org.apache.doris.datasource.hive.HivePartition> partitions = metaStoreCache.getAllPartitionsWithCache(
104104
hmsTable, new ArrayList<>(partitionValues.getPartitionValuesMap().values()));
105105
if (CollectionUtils.isEmpty(partitions)) {
106106
return new HiveSnapshotMeta(hmsTable.getName(), 0L);
107107
}
108-
HivePartition maxPartition = null;
108+
org.apache.doris.datasource.hive.HivePartition maxPartition = null;
109109
long maxTimestamp = 0L;
110110
List<Column> partitionColumns = hmsTable.getPartitionColumns(snapshot);
111-
for (HivePartition hivePartition : partitions) {
111+
for (org.apache.doris.datasource.hive.HivePartition hivePartition : partitions) {
112112
long currentTimestamp = hivePartition.getLastModifiedTime();
113113
if (currentTimestamp > maxTimestamp) {
114114
maxTimestamp = currentTimestamp;

fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/source/PaimonScanNode.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@ private void putHistorySchemaInfo(Long schemaId) {
213213
}
214214

215215
TableSchema tableSchema = PaimonUtils.getPaimonMetadataCache(source.getCatalog())
216-
.getPaimonSchemaCacheValue(targetTable.getOrBuildNameMapping(), schemaId).getTableSchema();
216+
.getPaimonSchemaCacheValue(targetTable, schemaId).getTableSchema();
217217
params.addToHistorySchemaInfo(PaimonUtil.getHistorySchemaInfo(targetTable, tableSchema,
218218
source.getCatalog().getEnableMappingVarbinary(),
219219
source.getCatalog().getEnableMappingTimestampTz()));

0 commit comments

Comments
 (0)