[incubator-seatunnel] branch dev updated: [Hotfix][Connector-V2] Fix connector source snapshot state NPE (#4027)

[fanjia]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new e39c4988c [Hotfix][Connector-V2] Fix connector source snapshot state 
NPE (#4027)
e39c4988c is described below

commit e39c4988ccfa99a7e6d01451eef899b770ea3cca
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Wed Feb 1 15:00:07 2023 +0800

    [Hotfix][Connector-V2] Fix connector source snapshot state NPE (#4027)
---
 release-note.md                                                        | 2 ++
 .../connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java | 3 ++-
 .../seatunnel/connectors/seatunnel/kudu/source/KuduSourceReader.java   | 3 ++-
 3 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/release-note.md b/release-note.md
index 616a0d0d6..9e66dec48 100644
--- a/release-note.md
+++ b/release-note.md
@@ -45,6 +45,8 @@
 ### Connectors
 - [ClickHouse File] Fix ClickhouseFile Committer Serializable Problems #3803
 - [ClickHouse] Fix clickhouse write cdc changelog update event #3951
+- [ClickHouse] Fix connector source snapshot state NPE #4027
+- [Kudu] Fix connector source snapshot state NPE #4027
 
 ### Zeta Engine
 - [Checkpoint] Fix Checkpoint Continue Trigger After Job CANCELED #3808
diff --git 
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java
 
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java
index 72a461061..3860962bf 100644
--- 
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java
+++ 
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java
@@ -31,6 +31,7 @@ import com.clickhouse.client.ClickHouseResponse;
 
 import java.io.IOException;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.Random;
 
@@ -88,7 +89,7 @@ public class ClickhouseSourceReader implements 
SourceReader<SeaTunnelRow, Clickh
 
     @Override
     public List<ClickhouseSourceSplit> snapshotState(long checkpointId) throws 
Exception {
-        return null;
+        return Collections.emptyList();
     }
 
     @Override
diff --git 
a/seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceReader.java
 
b/seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceReader.java
index 05e621bad..56253ca01 100644
--- 
a/seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceReader.java
+++ 
b/seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceReader.java
@@ -29,6 +29,7 @@ import org.apache.kudu.client.KuduScanner;
 import org.apache.kudu.client.RowResult;
 import org.apache.kudu.client.RowResultIterator;
 
+import java.util.Collections;
 import java.util.Deque;
 import java.util.LinkedList;
 import java.util.List;
@@ -85,7 +86,7 @@ public class KuduSourceReader implements 
SourceReader<SeaTunnelRow, KuduSourceSp
 
     @Override
     public List<KuduSourceSplit> snapshotState(long checkpointId) {
-        return null;
+        return Collections.emptyList();
     }
 
     @Override