This is an automated email from the ASF dual-hosted git repository.
zhangyue19921010 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 b361bbe739e [MINOR] Fix incorrect parameter usage when selecting
partition for TTL (#12631)
b361bbe739e is described below
commit b361bbe739ebd6974818b1b396207d1825acdb2d
Author: majian <[email protected]>
AuthorDate: Wed Jan 15 18:16:16 2025 +0800
[MINOR] Fix incorrect parameter usage when selecting partition for TTL
(#12631)
---
.../apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java
index 00cdb4185f5..dadbf06b7c9 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java
@@ -61,11 +61,11 @@ public abstract class PartitionTTLStrategy implements
TTLStrategy, Serializable
* @return all partitions paths for the dataset.
*/
protected List<String> getPartitionPathsForTTL() {
- String partitionSelected = writeConfig.getClusteringPartitionSelected();
+ String partitionSelected = writeConfig.getPartitionTTLPartitionSelected();
HoodieTimer timer = HoodieTimer.start();
List<String> partitionsForTTL;
if (StringUtils.isNullOrEmpty(partitionSelected)) {
- // Return All partition paths
+ // Return all partition paths.
partitionsForTTL = FSUtils.getAllPartitionPaths(
hoodieTable.getContext(), hoodieTable.getStorage(),
writeConfig.getMetadataConfig(), writeConfig.getBasePath());
} else {
