(hudi) branch master updated: [HUDI-7169] Comparison between defaultParName and partValue (#10234)

[danny0405]

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

danny0405 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 0b84b0074c4 [HUDI-7169] Comparison between defaultParName and 
partValue (#10234)
0b84b0074c4 is described below

commit 0b84b0074c48ef429e71d3016723bd0e9f0c0e1c
Author: hehuiyuan <471627...@qq.com>
AuthorDate: Thu Dec 7 12:04:02 2023 +0800

    [HUDI-7169] Comparison between defaultParName and partValue (#10234)
---
 .../src/main/java/org/apache/hudi/source/prune/PartitionPruners.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java
index 2acae0c6957..3f6338896d6 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java
@@ -94,7 +94,7 @@ public class PartitionPruners {
       Map<String, ColumnStats> partStats = new LinkedHashMap<>();
       for (int idx = 0; idx < partitionKeys.length; idx++) {
         String partKey = partitionKeys[idx];
-        Object partVal = partKey.equals(defaultParName)
+        Object partVal = partStrArray[idx].equals(defaultParName)
             ? null : DataTypeUtils.resolvePartition(partStrArray[idx], 
partitionTypes.get(idx));
         ColumnStats columnStats = new ColumnStats(partVal, partVal, partVal == 
null ? 1 : 0);
         partStats.put(partKey, columnStats);