Skip to content

Commit c318dc9

Browse files
author
xxhua
committed
partition location update with problem
1 parent 30e36f3 commit c318dc9

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ public void updatePartitionsToTable(String tableName, List<String> changedPartit
162162
StorageDescriptor partitionSd = sd.clone();
163163
String fullPartitionPath = FSUtils.getPartitionPath(getBasePath(), partition).toString();
164164
List<String> partitionValues = partitionValueExtractor.extractPartitionValuesInPath(partition);
165-
sd.setLocation(fullPartitionPath);
165+
partitionSd.setLocation(fullPartitionPath);
166166
PartitionInput partitionInput = new PartitionInput().withValues(partitionValues).withStorageDescriptor(partitionSd);
167167
return new BatchUpdatePartitionRequestEntry().withPartitionInput(partitionInput).withPartitionValueList(partitionValues);
168168
}).collect(Collectors.toList());

0 commit comments

Comments
 (0)