diff --git a/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/DingTalkSource.java b/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/DingTalkSource.java
index 7b56fd7381bc..130ca174b73c 100644
--- a/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/DingTalkSource.java
+++ b/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/DingTalkSource.java
@@ -32,7 +32,7 @@
 import org.apache.seatunnel.connectors.seatunnel.common.DingTalkConstant;
 import org.apache.seatunnel.connectors.seatunnel.common.DingTalkParameter;
 import org.apache.seatunnel.connectors.seatunnel.common.DingTalkUtil;
-import org.apache.seatunnel.connectors.seatunnel.common.schema.SeatunnelSchema;
+import org.apache.seatunnel.connectors.seatunnel.common.schema.SeaTunnelSchema;
 import org.apache.seatunnel.connectors.seatunnel.common.source.AbstractSingleSplitReader;
 import org.apache.seatunnel.connectors.seatunnel.common.source.AbstractSingleSplitSource;
 import org.apache.seatunnel.connectors.seatunnel.common.source.SingleSplitReaderContext;
@@ -85,9 +85,9 @@ public void prepare(Config pluginConfig) throws PrepareFailException {
 
         if (pluginConfig.hasPath(DingTalkConstant.SCHEMA)) {
             Config schema = pluginConfig.getConfig(DingTalkConstant.SCHEMA);
-            this.rowType = SeatunnelSchema.buildWithConfig(schema).getSeaTunnelRowType();
+            this.rowType = SeaTunnelSchema.buildWithConfig(schema).getSeaTunnelRowType();
         } else {
-            this.rowType = SeatunnelSchema.buildSimpleTextSchema();
+            this.rowType = SeaTunnelSchema.buildSimpleTextSchema();
         }
     }