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 e7d817f7d Avoid potential null pointer risk in
HiveSinkWriter#snapshotState (#2302)
e7d817f7d is described below
commit e7d817f7d27179203e07f790bc5c8cf1f34cfd51
Author: Xiao Zhao <[email protected]>
AuthorDate: Sat Jul 30 17:09:21 2022 +0800
Avoid potential null pointer risk in HiveSinkWriter#snapshotState (#2302)
---
.../seatunnel/connectors/seatunnel/hive/sink/HiveSinkWriter.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkWriter.java
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkWriter.java
index 4bdeae478..4aff955cd 100644
---
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkWriter.java
+++
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkWriter.java
@@ -36,6 +36,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
+import java.util.Collections;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
@@ -164,7 +165,7 @@ public class HiveSinkWriter implements
SinkWriter<SeaTunnelRow, HiveCommitInfo,
new HiveSinkState(state.getTransactionId(),
state.getCheckpointId()))
.collect(Collectors.toList());
}
- return null;
+ return Collections.emptyList();
}
@Override