Skip to content

Commit e39c498

Browse files
authored
[Hotfix][Connector-V2] Fix connector source snapshot state NPE (#4027)
1 parent 04b49e6 commit e39c498

File tree

3 files changed

+6
-2
lines changed

3 files changed

+6
-2
lines changed

release-note.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,8 @@
4545
### Connectors
4646
- [ClickHouse File] Fix ClickhouseFile Committer Serializable Problems #3803
4747
- [ClickHouse] Fix clickhouse write cdc changelog update event #3951
48+
- [ClickHouse] Fix connector source snapshot state NPE #4027
49+
- [Kudu] Fix connector source snapshot state NPE #4027
4850

4951
### Zeta Engine
5052
- [Checkpoint] Fix Checkpoint Continue Trigger After Job CANCELED #3808

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131

3232
import java.io.IOException;
3333
import java.util.ArrayList;
34+
import java.util.Collections;
3435
import java.util.List;
3536
import java.util.Random;
3637

@@ -88,7 +89,7 @@ public void pollNext(Collector<SeaTunnelRow> output) throws Exception {
8889

8990
@Override
9091
public List<ClickhouseSourceSplit> snapshotState(long checkpointId) throws Exception {
91-
return null;
92+
return Collections.emptyList();
9293
}
9394

9495
@Override

seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import org.apache.kudu.client.RowResult;
3030
import org.apache.kudu.client.RowResultIterator;
3131

32+
import java.util.Collections;
3233
import java.util.Deque;
3334
import java.util.LinkedList;
3435
import java.util.List;
@@ -85,7 +86,7 @@ public void pollNext(Collector<SeaTunnelRow> output) throws Exception {
8586

8687
@Override
8788
public List<KuduSourceSplit> snapshotState(long checkpointId) {
88-
return null;
89+
return Collections.emptyList();
8990
}
9091

9192
@Override

0 commit comments

Comments
 (0)