Skip to content

Commit 6ce4e83

Browse files
chenjian2664ebyhr
authored andcommitted
Add non-null check in MongoPageSink
1 parent 8b6983a commit 6ce4e83

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

plugin/trino-mongodb/src/main/java/io/trino/plugin/mongodb/MongoPageSink.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -98,9 +98,9 @@ public MongoPageSink(
9898
Optional<String> pageSinkIdColumnName,
9999
ConnectorPageSinkId pageSinkId)
100100
{
101-
this.mongoSession = mongoSession;
102-
this.remoteTableName = remoteTableName;
103-
this.columns = columns;
101+
this.mongoSession = requireNonNull(mongoSession, "mongoSession is null");
102+
this.remoteTableName = requireNonNull(remoteTableName, "remoteTableName is null");
103+
this.columns = ImmutableList.copyOf(requireNonNull(columns, "columns is null"));
104104
this.implicitPrefix = requireNonNull(implicitPrefix, "implicitPrefix is null");
105105
this.pageSinkIdColumnName = requireNonNull(pageSinkIdColumnName, "pageSinkIdColumnName is null");
106106
this.pageSinkId = requireNonNull(pageSinkId, "pageSinkId is null");

0 commit comments

Comments
 (0)