| commit | 6d72fc3242e7be76472412e4eb2ab16465b77c6e | [log] [tgz] |
|---|---|---|
| author | xxt <jia_yangchen@163.com> | Mon Feb 26 13:50:55 2024 +0800 |
| committer | GitHub <noreply@github.com> | Mon Feb 26 13:50:55 2024 +0800 |
| tree | c566d9168cbc8a755f1b709427ee1cf71f595806 | |
| parent | caf4cd76237c0c34511fc684833e75a5bac4cd08 [diff] |
[ISSUE-3085][Improve] Improve streampark-flink module based on [3.4 Collection Rule] returns List if use ArrayList Co-authored-by: xujiawei <xujiawei@do1.com.cn>
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 f8cee82..97ce5c8 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 @@ 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;