diff --git a/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java b/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java index 79651154ed63..d9c4ecd96af0 100644 --- a/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java +++ b/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java @@ -162,7 +162,7 @@ public void updatePartitionsToTable(String tableName, List changedPartit StorageDescriptor partitionSd = sd.clone(); String fullPartitionPath = FSUtils.getPartitionPath(getBasePath(), partition).toString(); List partitionValues = partitionValueExtractor.extractPartitionValuesInPath(partition); - sd.setLocation(fullPartitionPath); + partitionSd.setLocation(fullPartitionPath); PartitionInput partitionInput = new PartitionInput().withValues(partitionValues).withStorageDescriptor(partitionSd); return new BatchUpdatePartitionRequestEntry().withPartitionInput(partitionInput).withPartitionValueList(partitionValues); }).collect(Collectors.toList());