[incubator-seatunnel] branch dev updated: [style] Fix typo (#917)

[ki...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 943cf4b  [style] Fix typo (#917)
943cf4b is described below

commit 943cf4bf9464e00c17dad511e04f6e935587e5ab
Author: Guocheng Tang <48...@qq.com>
AuthorDate: Sat Jan 1 20:07:35 2022 +0800

    [style] Fix typo (#917)
    
    * Fix spell error
    
    * remove useless change
---
 .../utils/{SparkSturctTypeUtil.java => SparkStructTypeUtil.java}  | 8 +++-----
 .../main/scala/org/apache/seatunnel/spark/source/MongoDB.scala    | 4 ++--
 2 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkSturctTypeUtil.java b/seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkStructTypeUtil.java
similarity index 99%
rename from seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkSturctTypeUtil.java
rename to seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkStructTypeUtil.java
index d577811..67c8f3b 100644
--- a/seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkSturctTypeUtil.java
+++ b/seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkStructTypeUtil.java
@@ -17,6 +17,8 @@
 
 package org.apache.seatunnel.spark.utils;
 
+import com.alibaba.fastjson.JSONObject;
+import org.apache.seatunnel.common.config.ConfigRuntimeException;
 import org.apache.spark.sql.types.DataType;
 import org.apache.spark.sql.types.DataTypes;
 import org.apache.spark.sql.types.StructType;
@@ -24,11 +26,7 @@ import org.apache.spark.sql.types.StructType;
 import java.util.List;
 import java.util.Map;
 
-import com.alibaba.fastjson.JSONObject;
-
-import org.apache.seatunnel.common.config.ConfigRuntimeException;
-
-public class SparkSturctTypeUtil {
+public class SparkStructTypeUtil {
 
     public static StructType getStructType(StructType schema, JSONObject json) {
         StructType newSchema = schema.copy(schema.fields());
diff --git a/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala b/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala
index e4448a2..e4d2f05 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala
+++ b/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala
@@ -25,7 +25,7 @@ import org.apache.spark.sql.types.StructType
 import org.apache.seatunnel.common.config.{CheckResult, TypesafeConfigUtils}
 import org.apache.seatunnel.spark.SparkEnvironment
 import org.apache.seatunnel.spark.batch.SparkBatchSource
-import org.apache.seatunnel.spark.utils.SparkSturctTypeUtil
+import org.apache.seatunnel.spark.utils.SparkStructTypeUtil
 
 class MongoDB extends SparkBatchSource {
 
@@ -49,7 +49,7 @@ class MongoDB extends SparkBatchSource {
     config.hasPath("schema") match {
       case true => {
         val schemaJson = JSON.parseObject(config.getString("schema"))
-        schema = SparkSturctTypeUtil.getStructType(schema, schemaJson)
+        schema = SparkStructTypeUtil.getStructType(schema, schemaJson)
       }
       case false => {}
     }