(iotdb) branch master updated: flink-iotdb-connector: IoTDBSink throws NPE (#12133)

[rong]

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

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 4f3da09efad flink-iotdb-connector: IoTDBSink throws NPE (#12133)
4f3da09efad is described below

commit 4f3da09efadf53e142586dc364c6119d20bc97a7
Author: Xuan Ronaldo <xuanrona...@qq.com>
AuthorDate: Fri Mar 8 11:02:51 2024 +0800

    flink-iotdb-connector: IoTDBSink throws NPE (#12133)
---
 .../src/main/java/org/apache/iotdb/flink/IoTDBSink.java                 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
 
b/iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
index 5eee9b8fb3b..b215021541e 100644
--- 
a/iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
+++ 
b/iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
@@ -57,7 +57,7 @@ public class IoTDBSink<IN> extends RichSinkFunction<IN> {
 
   private int batchSize = 0;
   private int flushIntervalMs = 3000;
-  private transient List<Event> batchList;
+  private List<Event> batchList;
   private int sessionPoolSize = 2;
 
   public IoTDBSink(IoTDBSinkOptions options, IoTSerializationSchema<IN> 
schema) {