From 51602a34f7b2c296b1f1438e85ef2f12c4dff741 Mon Sep 17 00:00:00 2001 From: KnightChess <981159963@qq.com> Date: Thu, 2 Jun 2022 20:28:21 +0800 Subject: [PATCH] [HUDI-4179] Cluster with sort cloumns invalid (#5739) --- .../execution/bulkinsert/RDDCustomColumnsSortPartitioner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDCustomColumnsSortPartitioner.java b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDCustomColumnsSortPartitioner.java index b1cbe47a6..dc80498c7 100644 --- a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDCustomColumnsSortPartitioner.java +++ b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDCustomColumnsSortPartitioner.java @@ -68,7 +68,7 @@ public class RDDCustomColumnsSortPartitioner if (recordValue == null) { return StringUtils.EMPTY_STRING; } else { - return StringUtils.objToString(record); + return StringUtils.objToString(recordValue); } }, true, outputSparkPartitions);