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());