[improvement] replace lable to label (#3515)

apache · Jan 27, 2024 · 6a5c1fc · 6a5c1fc
1 parent deef9c2
commit 6a5c1fc
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/...s/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkWriter.java b/...s/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkWriter.java
@@ -166,7 +166,7 @@ public final synchronized void writeRecords(String database, String table, Strin
       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/...nnector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisConfig.scala b/...nnector-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/...ris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisSinkConfigOption.scala b/...ris/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])