(incubator-streampark) branch dev updated: [improvement] replace `lable` to `label` (#3515)

[benjobs]

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

benjobs 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 6a5c1fc49 [improvement] replace `lable` to `label` (#3515)
6a5c1fc49 is described below

commit 6a5c1fc493d44e9e002f603086b85299563367df
Author: fuchanghai <changha...@apache.org>
AuthorDate: Sat Jan 27 18:00:22 2024 +0800

    [improvement] replace `lable` to `label` (#3515)
---
 .../streampark/flink/connector/doris/internal/DorisSinkWriter.java    | 2 +-
 .../org/apache/streampark/connector/doris/conf/DorisConfig.scala      | 2 +-
 .../streampark/connector/doris/conf/DorisSinkConfigOption.scala       | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkWriter.java
 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkWriter.java
index a6f0d5317..160b32047 100644
--- 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkWriter.java
+++ 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkWriter.java
@@ -166,7 +166,7 @@ public class DorisSinkWriter implements Serializable {
       final String bufferKey = String.format("%s.%s", database, table);
       final DorisSinkBufferEntry bufferEntity =
           bufferMap.computeIfAbsent(
-              bufferKey, k -> new DorisSinkBufferEntry(database, table, 
dorisConfig.lablePrefix()));
+              bufferKey, k -> new DorisSinkBufferEntry(database, table, 
dorisConfig.labelPrefix()));
       for (String record : records) {
         byte[] bts = record.getBytes(StandardCharsets.UTF_8);
         bufferEntity.addToBuffer(bts);
diff --git 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisConfig.scala
 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisConfig.scala
index df09056c1..5407886e8 100644
--- 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisConfig.scala
+++ 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisConfig.scala
@@ -58,7 +58,7 @@ class DorisConfig(parameters: Properties) {
 
   val sinkOfferTimeout: Long = sinkOption.sinkOfferTimeout.get()
 
-  val lablePrefix: String = sinkOption.lablePrefix.get()
+  val labelPrefix: String = sinkOption.labelPrefix.get()
 
   val semantic: String = sinkOption.semantic.get()
 
diff --git 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisSinkConfigOption.scala
 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisSinkConfigOption.scala
index 2af63c3ec..933252d58 100644
--- 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisSinkConfigOption.scala
+++ 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisSinkConfigOption.scala
@@ -126,8 +126,8 @@ class DorisSinkConfigOption(prefixStr: String, properties: 
Properties) extends S
   val maxRetries: ConfigOption[Int] =
     ConfigOption(key = "maxRetries", required = false, defaultValue = 1, 
classType = classOf[Int])
 
-  val lablePrefix: ConfigOption[String] = ConfigOption(
-    key = "lablePrefix",
+  val labelPrefix: ConfigOption[String] = ConfigOption(
+    key = "labelPrefix",
     required = false,
     defaultValue = "doris",
     classType = classOf[String])