diff --git a/dinky-app/dinky-app-1.12/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.12/src/main/java/org/dinky/app/MainApp.java
index 31f98e97a5..2fa5f72be7 100644
--- a/dinky-app/dinky-app-1.12/src/main/java/org/dinky/app/MainApp.java
+++ b/dinky-app/dinky-app-1.12/src/main/java/org/dinky/app/MainApp.java
@@ -20,7 +20,7 @@
 package org.dinky.app;
 
 import org.dinky.app.db.DBConfig;
-import org.dinky.app.flinksql.Submiter;
+import org.dinky.app.flinksql.Submitter;
 import org.dinky.assertion.Asserts;
 import org.dinky.constant.FlinkParamConstant;
 import org.dinky.utils.FlinkBaseUtil;
@@ -41,6 +41,6 @@ public static void main(String[] args) throws IOException {
         String id = params.get(FlinkParamConstant.ID);
         Asserts.checkNullString(id, "请配置入参 id ");
         DBConfig dbConfig = DBConfig.build(params);
-        Submiter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
+        Submitter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
     }
 }
diff --git a/dinky-app/dinky-app-1.13/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.13/src/main/java/org/dinky/app/MainApp.java
index 31f98e97a5..2fa5f72be7 100644
--- a/dinky-app/dinky-app-1.13/src/main/java/org/dinky/app/MainApp.java
+++ b/dinky-app/dinky-app-1.13/src/main/java/org/dinky/app/MainApp.java
@@ -20,7 +20,7 @@
 package org.dinky.app;
 
 import org.dinky.app.db.DBConfig;
-import org.dinky.app.flinksql.Submiter;
+import org.dinky.app.flinksql.Submitter;
 import org.dinky.assertion.Asserts;
 import org.dinky.constant.FlinkParamConstant;
 import org.dinky.utils.FlinkBaseUtil;
@@ -41,6 +41,6 @@ public static void main(String[] args) throws IOException {
         String id = params.get(FlinkParamConstant.ID);
         Asserts.checkNullString(id, "请配置入参 id ");
         DBConfig dbConfig = DBConfig.build(params);
-        Submiter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
+        Submitter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
     }
 }
diff --git a/dinky-app/dinky-app-1.14/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.14/src/main/java/org/dinky/app/MainApp.java
index 31f98e97a5..2fa5f72be7 100644
--- a/dinky-app/dinky-app-1.14/src/main/java/org/dinky/app/MainApp.java
+++ b/dinky-app/dinky-app-1.14/src/main/java/org/dinky/app/MainApp.java
@@ -20,7 +20,7 @@
 package org.dinky.app;
 
 import org.dinky.app.db.DBConfig;
-import org.dinky.app.flinksql.Submiter;
+import org.dinky.app.flinksql.Submitter;
 import org.dinky.assertion.Asserts;
 import org.dinky.constant.FlinkParamConstant;
 import org.dinky.utils.FlinkBaseUtil;
@@ -41,6 +41,6 @@ public static void main(String[] args) throws IOException {
         String id = params.get(FlinkParamConstant.ID);
         Asserts.checkNullString(id, "请配置入参 id ");
         DBConfig dbConfig = DBConfig.build(params);
-        Submiter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
+        Submitter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
     }
 }
diff --git a/dinky-app/dinky-app-1.15/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.15/src/main/java/org/dinky/app/MainApp.java
index 31f98e97a5..2fa5f72be7 100644
--- a/dinky-app/dinky-app-1.15/src/main/java/org/dinky/app/MainApp.java
+++ b/dinky-app/dinky-app-1.15/src/main/java/org/dinky/app/MainApp.java
@@ -20,7 +20,7 @@
 package org.dinky.app;
 
 import org.dinky.app.db.DBConfig;
-import org.dinky.app.flinksql.Submiter;
+import org.dinky.app.flinksql.Submitter;
 import org.dinky.assertion.Asserts;
 import org.dinky.constant.FlinkParamConstant;
 import org.dinky.utils.FlinkBaseUtil;
@@ -41,6 +41,6 @@ public static void main(String[] args) throws IOException {
         String id = params.get(FlinkParamConstant.ID);
         Asserts.checkNullString(id, "请配置入参 id ");
         DBConfig dbConfig = DBConfig.build(params);
-        Submiter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
+        Submitter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
     }
 }
diff --git a/dinky-app/dinky-app-1.16/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.16/src/main/java/org/dinky/app/MainApp.java
index d029b6a697..5d10723cf6 100644
--- a/dinky-app/dinky-app-1.16/src/main/java/org/dinky/app/MainApp.java
+++ b/dinky-app/dinky-app-1.16/src/main/java/org/dinky/app/MainApp.java
@@ -20,7 +20,7 @@
 package org.dinky.app;
 
 import org.dinky.app.db.DBConfig;
-import org.dinky.app.flinksql.Submiter;
+import org.dinky.app.flinksql.Submitter;
 import org.dinky.assertion.Asserts;
 import org.dinky.constant.FlinkParamConstant;
 import org.dinky.utils.FlinkBaseUtil;
@@ -41,6 +41,6 @@ public static void main(String[] args) throws IOException {
         String id = params.get(FlinkParamConstant.ID);
         Asserts.checkNullString(id, "请配置入参 id ");
         DBConfig dbConfig = DBConfig.build(params);
-        Submiter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
+        Submitter.submit(Integer.valueOf(id), dbConfig, params.get(FlinkParamConstant.DINKY_ADDR));
     }
 }
diff --git a/dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submiter.java b/dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submitter.java
similarity index 98%
rename from dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submiter.java
rename to dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submitter.java
index 1e7c607734..2ea2434433 100644
--- a/dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submiter.java
+++ b/dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submitter.java
@@ -67,9 +67,9 @@
  * @author wenmo
  * @since 2021/10/27
  */
-public class Submiter {
+public class Submitter {
 
-    private static final Logger logger = LoggerFactory.getLogger(Submiter.class);
+    private static final Logger logger = LoggerFactory.getLogger(Submitter.class);
     private static final String NULL = "null";
 
     private static String getQuerySQL(Integer id) throws SQLException {
@@ -156,7 +156,7 @@ public static void submit(Integer id, DBConfig dbConfig, String dinkyAddr) {
             dinkyAddr = "";
         }
         StringBuilder sb = new StringBuilder();
-        Map<String, String> taskConfig = Submiter.getTaskConfig(id, dbConfig);
+        Map<String, String> taskConfig = Submitter.getTaskConfig(id, dbConfig);
 
         if (Asserts.isNotNull(taskConfig.get("envId"))) {
             String envId = getFlinkSQLStatement(Integer.valueOf(taskConfig.get("envId")), dbConfig);
@@ -169,7 +169,7 @@ public static void submit(Integer id, DBConfig dbConfig, String dinkyAddr) {
         sb.append(getDbSourceSqlStatements(dbConfig, id));
         // 添加自定义全局变量信息
         sb.append(getFlinkSQLStatement(id, dbConfig));
-        List<String> statements = Submiter.getStatements(sb.toString());
+        List<String> statements = Submitter.getStatements(sb.toString());
         ExecutorSetting executorSetting = ExecutorSetting.build(taskConfig);
 
         // 加载第三方jar