[improvement] replace `lable` to `label` (#3515)
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 a6f0d53..160b320 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 @@
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 df09056..5407886 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 @@
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 2af63c3..933252d 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 @@
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])
