fix

apache · Jun 1, 2023 · 64197d1 · 64197d1
1 parent 1adb461
commit 64197d1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...c/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongoKeyExtractor.java b/...c/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/...ain/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriterOptions.java b/...ain/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;
         }