(hudi) branch master updated: perf(kafka-connect): use a pre-sized ArrayList when flushing buffered records (#19017)

[wombatukun]

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

wombatu-kun 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 8c2eacffb160 perf(kafka-connect): use a pre-sized ArrayList when 
flushing buffered records (#19017)
8c2eacffb160 is described below

commit 8c2eacffb160c8e45d9940c738f41ea7bd94c831
Author: Vova Kolmakov <wombatu...@gmail.com>
AuthorDate: Tue Jun 16 20:36:27 2026 +0700

    perf(kafka-connect): use a pre-sized ArrayList when flushing buffered 
records (#19017)
---
 .../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());
         }
       }