[incubator-streampark] branch dev updated: Fix typos in the code (#2839)

[zhouli]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new d51e837c2 Fix typos in the code (#2839)
d51e837c2 is described below

commit d51e837c275655835ecefc0ae7fd365ebd11a1eb
Author: onlyotdn <138647779+onlyo...@users.noreply.github.com>
AuthorDate: Sat Jul 8 00:20:57 2023 +0800

    Fix typos in the code (#2839)
---
 .../org/apache/streampark/console/core/runner/EnvInitializer.java     | 2 +-
 .../streampark/flink/connector/doris/internal/DorisSinkFunction.java  | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
index c2f405343..a98213619 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
@@ -87,7 +87,7 @@ public class EnvInitializer implements ApplicationRunner {
               "[StreamPark] System initialization check failed,"
                   + " The system initialization check failed. If started local 
for development and debugging,"
                   + " please ensure the -D%s parameter is clearly specified,"
-                  + " more detail: 
https://streampark.apache.org/docs/user-guide/development";,
+                  + " more detail: 
https://streampark.apache.org/docs/user-guide/deployment";,
               ConfigConst.KEY_APP_HOME()));
     }
 
diff --git 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkFunction.java
 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkFunction.java
index 5018d2451..8360e0d24 100644
--- 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkFunction.java
+++ 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkFunction.java
@@ -83,7 +83,7 @@ public class DorisSinkFunction<T> extends RichSinkFunction<T> 
implements Checkpo
           || null == data.getDataRows()) {
         LOGGER.warn(
             String.format(
-                " row data not fullfilled. {database: %s, table: %s, dataRows: 
%s}",
+                " row data not fulfilled. {database: %s, table: %s, dataRows: 
%s}",
                 data.getDatabase(), data.getTable(), data.getDataRows()));
         return;
       }
@@ -91,7 +91,7 @@ public class DorisSinkFunction<T> extends RichSinkFunction<T> 
implements Checkpo
     } else {
       if (StringUtils.isEmpty(dorisConfig.database()) || 
StringUtils.isEmpty(dorisConfig.table())) {
         throw new RuntimeException(
-            " database|table  is empt ,please check your config or create 
DorisSinkRowDataWithMeta instance");
+            " database|table  is empty ,please check your config or create 
DorisSinkRowDataWithMeta instance");
       }
       dorisSinkWriter.writeRecords(dorisConfig.database(), 
dorisConfig.table(), (String) value);
     }