diff --git a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongoKeyExtractor.java b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongoKeyExtractor.java
index d8604dbc5995..fe3aff6ae100 100644
--- a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongoKeyExtractor.java
+++ b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongoKeyExtractor.java
@@ -28,15 +28,15 @@ public class MongoKeyExtractor implements SerializableFunction<BsonDocument, Bso
 
     private static final long serialVersionUID = 1L;
 
-    private final String[] upsertKey;
+    private final String[] primaryKey;
 
     public MongoKeyExtractor(MongodbWriterOptions options) {
-        upsertKey = options.getPrimaryKey();
+        primaryKey = options.getPrimaryKey();
     }
 
     @Override
     public BsonDocument apply(BsonDocument bsonDocument) {
-        return Arrays.stream(upsertKey)
+        return Arrays.stream(primaryKey)
                 .filter(bsonDocument::containsKey)
                 .collect(
                         Collectors.toMap(
diff --git a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriterOptions.java b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriterOptions.java
index acd0ef1af4de..be8becd3275d 100644
--- a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriterOptions.java
+++ b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriterOptions.java
@@ -119,7 +119,7 @@ public Builder withUpsertEnable(boolean upsertEnable) {
             return this;
         }
 
-        public Builder withPrimaryKey(String[] upsertKey) {
+        public Builder withPrimaryKey(String[] primaryKey) {
             this.primaryKey = primaryKey;
             return this;
         }