This is an automated email from the ASF dual-hosted git repository. codope pushed a commit to branch release-0.12.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 76cc3c9c4da80cfb620ecc5dcedf3e79176e1370 Author: HunterXHunter <[email protected]> AuthorDate: Fri Aug 5 19:30:26 2022 +0800 [HUDI-4547] Fix SortOperatorGen sort indices (#6309) Signed-off-by: HunterXHunter <[email protected]> --- .../main/java/org/apache/hudi/sink/bulk/sort/SortOperatorGen.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperatorGen.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperatorGen.java index b5599886a9..e6821e667e 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperatorGen.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperatorGen.java @@ -26,7 +26,6 @@ import org.apache.flink.table.planner.plan.nodes.exec.spec.SortSpec; import org.apache.flink.table.types.logical.RowType; import java.util.Arrays; -import java.util.stream.IntStream; /** * Tools to generate the sort operator. @@ -50,7 +49,9 @@ public class SortOperatorGen { public SortCodeGenerator createSortCodeGenerator() { SortSpec.SortSpecBuilder builder = SortSpec.builder(); - IntStream.range(0, sortIndices.length).forEach(i -> builder.addField(i, true, true)); + for (int sortIndex : sortIndices) { + builder.addField(sortIndex, true, true); + } return new SortCodeGenerator(tableConfig, rowType, builder.build()); } }
