[HUDI-4179] cluster with sort cloumns invalid

KnightChess · KnightChess · commit 0008477614e5 · 2022-06-02T15:49:53.000+08:00
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
@@ -68,7 +68,7 @@ record -> {
           if (recordValue == null) {
             return StringUtils.EMPTY_STRING;
           } else {
-            return StringUtils.objToString(record);
+            return StringUtils.objToString(recordValue);
           }
         },
         true, outputSparkPartitions);

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ record -> {`
`68`	`68`	`if (recordValue == null) {`
`69`	`69`	`return StringUtils.EMPTY_STRING;`
`70`	`70`	`} else {`
`71`		`- return StringUtils.objToString(record);`
	`71`	`+ return StringUtils.objToString(recordValue);`
`72`	`72`	`}`
`73`	`73`	`},`
`74`	`74`	`true, outputSparkPartitions);`