[incubator-seatunnel] branch dev updated: Avoid potential null pointer risk in HiveSinkWriter#snapshotState (#2302)

[fa...@apache.org]

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 <zh...@163.com>
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