From b7a819bd245b6463b83bd3a33dccb6ec164e1d84 Mon Sep 17 00:00:00 2001 From: abmdocrt Date: Tue, 9 Jan 2024 16:41:31 +0800 Subject: [PATCH] [Fix](typo) Fix analyzeGroupCommitDataBytes typo #29640 --- .../java/org/apache/doris/common/util/PropertyAnalyzer.java | 2 +- .../main/java/org/apache/doris/datasource/InternalCatalog.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java index 8699c9db43..8a4051c9af 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java @@ -1217,7 +1217,7 @@ public class PropertyAnalyzer { return groupCommitIntervalMs; } - public static int analyzeGroupCommitDateBytes(Map properties) throws AnalysisException { + public static int analyzeGroupCommitDataBytes(Map properties) throws AnalysisException { int groupCommitDataBytes = PROPERTIES_GROUP_COMMIT_DATA_BYTES_DEFAULT_VALUE; if (properties != null && properties.containsKey(PROPERTIES_GROUP_COMMIT_DATA_BYTES)) { String groupIntervalCommitDataBytesStr = properties.get(PROPERTIES_GROUP_COMMIT_DATA_BYTES); diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java index da8afec263..280ebf3e67 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java @@ -2438,7 +2438,7 @@ public class InternalCatalog implements CatalogIf { int groupCommitDataBytes; try { - groupCommitDataBytes = PropertyAnalyzer.analyzeGroupCommitDateBytes(properties); + groupCommitDataBytes = PropertyAnalyzer.analyzeGroupCommitDataBytes(properties); olapTable.setGroupCommitDataBytes(groupCommitDataBytes); } catch (Exception e) { throw new DdlException(e.getMessage());