This is an automated email from the ASF dual-hosted git repository. benjobs pushed a commit to branch doris-connector in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit f73a86c905bd1be16f2c490c4fb5aa25ff6dce96 Author: benjobs <[email protected]> AuthorDate: Sun Jan 28 12:25:43 2024 +0800 [Improve] doris-connector typo improvement --- .../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 a38f2cee3..f031282a6 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 a4940df84..6ec700b32 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])
