(incubator-streampark) branch dev updated: [ISSUE-3085][Improve] Improve streampark-flink module based on [3.4 Collection Rule]

[cancai]

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

cancai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 6d72fc324 [ISSUE-3085][Improve] Improve streampark-flink module based 
on [3.4 Collection Rule]
6d72fc324 is described below

commit 6d72fc3242e7be76472412e4eb2ab16465b77c6e
Author: xxt <jia_yangc...@163.com>
AuthorDate: Mon Feb 26 13:50:55 2024 +0800

    [ISSUE-3085][Improve] Improve streampark-flink module based on [3.4 
Collection Rule]
    
    returns List if use ArrayList
    
    Co-authored-by: xujiawei <xujia...@do1.com.cn>
---
 .../streampark/flink/connector/doris/bean/DorisSinkBufferEntry.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/bean/DorisSinkBufferEntry.java
 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/bean/DorisSinkBufferEntry.java
index f8cee820a..97ce5c8f5 100644
--- 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/bean/DorisSinkBufferEntry.java
+++ 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/bean/DorisSinkBufferEntry.java
@@ -26,11 +26,11 @@ public class DorisSinkBufferEntry implements Serializable {
 
   private static final long serialVersionUID = 1L;
 
-  public ArrayList<byte[]> getBuffer() {
+  public List<byte[]> getBuffer() {
     return buffer;
   }
 
-  private ArrayList<byte[]> buffer = new ArrayList<>();
+  private List<byte[]> buffer = new ArrayList<>();
   private int batchCount = 0;
   private long batchSize = 0;
   private String label;