diff --git a/internal/util/paramtable/component_param.go b/internal/util/paramtable/component_param.go index f285c75a3d..8cfbbdf010 100644 --- a/internal/util/paramtable/component_param.go +++ b/internal/util/paramtable/component_param.go @@ -1382,7 +1382,7 @@ func (p *dataNodeConfig) initFlowGraphMaxParallelism() { } func (p *dataNodeConfig) initFlushInsertBufferSize() { - bufferSize := p.Base.LoadWithDefault2([]string{"DATA_NODE_IBUFSIZE", "datanode.segment.insertBufSize"}, "0") + bufferSize := p.Base.LoadWithDefault2([]string{"DATA_NODE_IBUFSIZE", "datanode.segment.insertBufSize"}, "16777216") bs, err := strconv.ParseInt(bufferSize, 10, 64) if err != nil { panic(err)