mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-11-21 14:44:00 +00:00
7a8b92b590
- Maintain a separate worker pool per each part type (in-memory, file, big and small).
Previously a shared pool was used for merging all the part types.
A single merge worker could merge parts with mixed types at once. For example,
it could merge simultaneously an in-memory part plus a big file part.
Such a merge could take hours for big file part. During the duration of this merge
the in-memory part was pinned in memory and couldn't be persisted to disk
under the configured -inmemoryDataFlushInterval .
Another common issue, which could happen when parts with mixed types are merged,
is uncontrolled growth of in-memory parts or small parts when all the merge workers
were busy with merging big files. Such growth could lead to significant performance
degradataion for queries, since every query needs to check ever growing list of parts.
This could also slow down the registration of new time series, since VictoriaMetrics
searches for the internal series_id in the indexdb for every new time series.
The third issue is graceful shutdown duration, which could be very long when a background
merge is running on in-memory parts plus big file parts. This merge couldn't be interrupted,
since it merges in-memory parts.
A separate pool of merge workers per every part type elegantly resolves both issues:
- In-memory parts are merged to file-based parts in a timely manner, since the maximum
size of in-memory parts is limited.
- Long-running merges for big parts do not block merges for in-memory parts and small parts.
- Graceful shutdown duration is now limited by the time needed for flushing in-memory parts to files.
Merging for file parts is instantly canceled on graceful shutdown now.
- Deprecate -smallMergeConcurrency command-line flag, since the new background merge algorithm
should automatically self-tune according to the number of available CPU cores.
- Deprecate -finalMergeDelay command-line flag, since it wasn't working correctly.
It is better to run forced merge when needed - https://docs.victoriametrics.com/#forced-merge
- Tune the number of shards for pending rows and items before the data goes to in-memory parts
and becomes visible for search. This improves the maximum data ingestion rate and the maximum rate
for registration of new time series. This should reduce the duration of data ingestion slowdown
in VictoriaMetrics cluster on e.g. re-routing events, when some of vmstorage nodes become temporarily
unavailable.
- Prevent from possible "sync: WaitGroup misuse" panic on graceful shutdown.
This is a follow-up for
|
||
|---|---|---|
| .. | ||
| block.go | ||
| block_header.go | ||
| block_header_test.go | ||
| block_stream_merger.go | ||
| block_stream_reader.go | ||
| block_stream_reader_test.go | ||
| block_stream_reader_timing_test.go | ||
| block_stream_writer.go | ||
| block_stream_writer_timing_test.go | ||
| block_test.go | ||
| dedup.go | ||
| dedup_test.go | ||
| dedup_timing_test.go | ||
| filenames.go | ||
| index_db.go | ||
| index_db_test.go | ||
| index_db_timing_test.go | ||
| inmemory_part.go | ||
| inmemory_part_test.go | ||
| inmemory_part_timing_test.go | ||
| merge.go | ||
| merge_test.go | ||
| merge_timing_test.go | ||
| metaindex_row.go | ||
| metaindex_row_test.go | ||
| metric_name.go | ||
| metric_name_test.go | ||
| part.go | ||
| part_header.go | ||
| part_search.go | ||
| part_search_test.go | ||
| part_search_timing_test.go | ||
| partition.go | ||
| partition_search.go | ||
| partition_search_test.go | ||
| partition_test.go | ||
| raw_block.go | ||
| raw_row.go | ||
| search.go | ||
| search_test.go | ||
| storage.go | ||
| storage_test.go | ||
| storage_timing_test.go | ||
| table.go | ||
| table_search.go | ||
| table_search_test.go | ||
| table_search_timing_test.go | ||
| table_test.go | ||
| table_timing_test.go | ||
| tag_filters.go | ||
| tag_filters_test.go | ||
| tag_filters_timing_test.go | ||
| time.go | ||
| time_test.go | ||
| tsid.go | ||
| tsid_test.go | ||