You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by xu...@apache.org on 2022/09/01 04:23:43 UTC

[hudi] branch master updated: [HUDI-4742] Fix AWS Glue partition's location is wrong when updatePartition (#6545)

This is an automated email from the ASF dual-hosted git repository.

xushiyan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 5d9db864f1 [HUDI-4742] Fix AWS Glue partition's location is wrong when updatePartition (#6545)
5d9db864f1 is described below

commit 5d9db864f1ca77e49ea3e7d90e193ac05feeaa01
Author: Xixi Hua <sm...@gmail.com>
AuthorDate: Thu Sep 1 12:23:37 2022 +0800

    [HUDI-4742] Fix AWS Glue partition's location is wrong when updatePartition (#6545)
    
    Co-authored-by: xxhua <xx...@freewheel.tv>
---
 .../main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 79651154ed..d9c4ecd96a 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 class AWSGlueCatalogSyncClient extends HoodieSyncClient {
         StorageDescriptor partitionSd = sd.clone();
         String fullPartitionPath = FSUtils.getPartitionPath(getBasePath(), partition).toString();
         List<String> 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());