This is an automated email from the ASF dual-hosted git repository. voonhous pushed a commit to branch release-1.2.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 98ad512fe59ee616d92afe8e6c20f331c8c84e96 Author: Vova Kolmakov <[email protected]> AuthorDate: Tue Jun 16 20:36:27 2026 +0700 perf(kafka-connect): use a pre-sized ArrayList when flushing buffered records (#19017) (cherry picked from commit 8c2eacffb160c8e45d9940c738f41ea7bd94c831) --- .../java/org/apache/hudi/connect/writers/BufferedConnectWriter.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/BufferedConnectWriter.java b/hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/BufferedConnectWriter.java index 2893839acd75..09b61ae608fa 100644 --- a/hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/BufferedConnectWriter.java +++ b/hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/BufferedConnectWriter.java @@ -40,7 +40,6 @@ import lombok.extern.slf4j.Slf4j; import java.io.IOException; import java.util.ArrayList; -import java.util.LinkedList; import java.util.List; /** @@ -109,11 +108,11 @@ public class BufferedConnectWriter extends AbstractConnectWriter { if (!bufferedRecords.isEmpty()) { if (isMorTable) { writeStatuses = writeClient.upsertPreppedRecords( - new LinkedList<>(bufferedRecords.values()), + new ArrayList<>(bufferedRecords.values()), instantTime); } else { writeStatuses = writeClient.bulkInsertPreppedRecords( - new LinkedList<>(bufferedRecords.values()), + new ArrayList<>(bufferedRecords.values()), instantTime, Option.empty()); } }
