diff --git a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java
index 1126c27353d6..6215afb74ef0 100644
--- a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java
+++ b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java
@@ -33,7 +33,8 @@
 import org.apache.seatunnel.connectors.seatunnel.cdc.mongodb.config.MongodbSourceOptions;
 
 import com.google.auto.service.AutoService;
-import com.sun.istack.internal.NotNull;
+
+import javax.annotation.Nonnull;
 
 import java.io.Serializable;
 import java.util.Collections;
@@ -97,7 +98,7 @@ TableSource<T, SplitT, StateT> createSource(TableFactoryContext context) {
     }
 
     @Override
-    public Result applyTables(@NotNull TableFactoryContext context) {
+    public Result applyTables(@Nonnull TableFactoryContext context) {
         return Result.of(context.getCatalogTables(), Collections.emptyList());
     }
 }