83 Commits (main)

Author	SHA1	Message	Date
Ivan Kalita	7da73aaa7e	chore(dataobj): optimize bitmap decoder (#20467) ... - Use pkg/memory.Bitmap instead of []Value for pageReader presence bitmap - More efficient decoding for bitmapDecoder - only support 0/1 values (this encoding is used only for presence bitmap).	20 hours ago
George Robinson	27df4ab481	feat: create separate flusher to support parallel flushes (#20446)	1 day ago
George Robinson	6a8b879d8f	feat: add support for cancelation to copy and sort (#20370)	5 days ago
George Robinson	ed4f27ed60	feat: add metric to track flush failures (#20399)	7 days ago
Dylan Guedes	498656bbe7	feat: Add new dataobj builder flush criteria (#20323)	1 week ago
George Robinson	533b1f0ae8	chore: remove unregister metrics (#20385)	2 weeks ago
George Robinson	3acb3106bb	feat: remove final flush (#20360)	2 weeks ago
George Robinson	c3e909d538	feat: decouple dataobj consumers from the reader service (#20315)	2 weeks ago
George Robinson	5a5e90e9f7	feat: add histogram loki_dataobj_consumer_flush_duration_seconds (#20304)	2 weeks ago
George Robinson	fba0c5d8a6	feat: dataobj-consumer add processed bytes metric (#20303)	2 weeks ago
George Robinson	bd77a47df9	chore: remove use of namespace/subsystem in builder metrics (#20301)	2 weeks ago
George Robinson	e0e5d78e69	chore: move appends total metric into builder (#20300)	2 weeks ago
George Robinson	a03e00a3bc	chore: better comments when end offset is zero (#20196)	1 month ago
George Robinson	333da739c7	feat: add processed records metric (#20191)	1 month ago
George Robinson	c0c27b3596	feat: add downscalePermittedFunc to check downscale is permitted (#20171)	1 month ago
benclive	225a0595ac	chore: Define an E2E ingestion processing time metric (#20054)	2 months ago
Ivan Kalita	3559d4bd42	chore(metastore): add column reader for pointers section (#19992) ... Adding columnar reader for (log)pointers section. Using it to read the stream section pointers. New reader is slower than existing RowReader due to double-translation of the data (columns->rows->rows vs columns->rows->columns->rows). The idea though is to get rid of the double-translation in the future.	2 months ago
Christian Haudum	8b59b944f2	chore(dataobj): Use common base config for indexobj and logsobj builders (#20037) ... Use the same config struct for both the indexobj builder and the logsobj builder, since they are configured identically, only with different default values.	2 months ago
George Robinson	677b2ecda1	feat: add prepare downscale handler (#20007)	2 months ago
George Robinson	9fb90309c0	chore: clean up prepare downscale handler (#20006)	2 months ago
Paul Rogers	91d4eb6ce1	feat: Add partition state to consumption lag metric (#19912)	2 months ago
George Robinson	a28e755e79	chore: rename the prepare delayed downscale handler to better communicate what it does (#19727)	2 months ago
George Robinson	0af297cd4c	chore: remove loki_dataobj_consumer_processing_delay histogram (#19718)	2 months ago
Christian Haudum	0b4a7f5a2c	chore(dataobj-consumer): Re-use builder for CopyAndSort() (#19696) ... Re-use logsobj.Builder instance in partition processor when sorting logs object wide after flushing. The metrics for the builder in CopyAndSort are never registered, which means the loki_dataobj_sort_duration_seconds histogram is never exported/scraped. We cannot register them with RegisterMetrics() because the metrics are already registered here, and registering them twice would cause a panic.	3 months ago
benclive	6ee50064ea	chore: Ensure partition is set on partition-processor (#19693)	3 months ago
George Robinson	da37290a40	fix: loki_dataobj_sort_duration_seconds never registered (#19679)	3 months ago
George Robinson	977fb2ba6f	feat: consume single topics in dataobj-consumer using partition ring (#19186)	3 months ago
Ashwanth	fa8bd848f6	chore: update buildTable to sort rows using `BuilderOptions.SortOrder` (#19515)	3 months ago
Christian Haudum	c06eb636e5	chore(engine): Add "compatibility node" to physical plan to adhere with naming of "colliding labels" in v1 engine (#19470) ... ### Summary The v1 engine has a mechanism to rename labels in case they have the same name but different origin, such as labels, structured metadata, or parsed fields. 1. In case a log line has a structured metadata key with the same name as the label name of the stream, than the metadata key is suffixed with `_extracted`, such as `service_extracted`, if `service` exists in both `labels` and `metadata`. 2. In case a parser creates a parsed field with the same as the label name of the stream, then the parsed key is suffixed with `_extracted` in the same way as case 1. However, if the field name also collides with a structured metadata key, then the extracted structured metadata is replaced with the extracted parsed field. This PR only implements the first case. As a follow up PR, the second case needs to be implemented as well. Additionally, the newly introduced "compatibility node" should also be made optional with a feature flag and/or per-request. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	3 months ago
Christian Haudum	386d4e1653	chore(dataobj): Make logs sort order in dataobjects configurable (#19373) ... This PR introduces a new configuration option `-dataobj-consumer.dataobj-sort-order` which controls the sort order of logs in the logs section of the dataobj when building new objects. There are two available sort options: 1. `timestamp DESC, streamID ASC` (configuration value `timestamp-desc`) 2. `streamID ASC, timestamp DESC` (configuration value `stream-asc`) The new setting is undocumented and may be removed in the future without notice. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	4 months ago
Christian Haudum	a3017f2b13	chore(dataobj-consumer): Sort logs object-wide (#19231) ... Sorting logs globally (object-wide per tenant) removes overlapping time ranges of sections in the objects. Sections contain logs from multiple streams, and the ingest lag of streams may vary. This means that although logs of individual sections are sorted by timestamp, the overall sorting of logs is not guaranteed. Therefore sections are sorted with a k-way merge (SortMerge), which does over-query data in case the query would reach its result limit early. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	4 months ago
Christian Haudum	4c81ebc7c3	chore(dataobj): Add option to set target row limit for pages (#19128) ... This PR introduces an option for the column builder to limit the number of rows in a page. It can be set for logs object and index objects separately using `-dataobj-consumer.max-page-rows` and `-dataobj-index-builder.max-page-rows` respectively. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	4 months ago
benclive	653d7ac19e	chore: Fix tenant info in sections when resetting (#19085) ... Co-authored-by: George Robinson <george.robinson@grafana.com>	5 months ago
George Robinson	f60f818bdd	feat: build multi-tenant data objects (#19034)	5 months ago
George Robinson	44aba62243	fix: fix possible data loss in dataobj-consumers (#19060)	5 months ago
benclive	2d30c6a5a4	chore: Implement building multi-tenant indexes from multi-tenant objects (#18959)	5 months ago
benclive	0b9b4c1ee5	chore: Support multi-tenancy in indexobj builder (#18880)	5 months ago
George Robinson	d8b22bfef8	fix: deadlock when shutting down dataobj-consumers (#18932)	5 months ago
benclive	d93a44141f	chore: Make metastore event synchronous (#18928)	5 months ago
George Robinson	20d93e3a8d	chore: rename lastFlush to lastFlushed and move some tests (#18918)	5 months ago
George Robinson	3ed2c4e127	chore: add safety check for estimated size (#18919)	5 months ago
George Robinson	058eaa7e0b	chore: improve flush unit tests with better separation (#18917)	5 months ago
George Robinson	31d5f1a738	fix: reset the last modified timestamp on flush (#18916)	5 months ago
George Robinson	278374609d	chore: create a factory to create partition processors (#18897)	5 months ago
George Robinson	4608048388	chore: remove unused sync.Pool (#18895)	5 months ago
George Robinson	be7ff4b294	chore: add flushAndCommit to make it harder to forget to commit offsets in future (#18851)	5 months ago
George Robinson	0941b90614	fix: dataobj-consumers did not commit offsets on idle flush (#18834)	5 months ago
George Robinson	8895090643	fix: dataobj-consumers commit incorrect offset, which can cause data loss (#18833)	5 months ago
benclive	e57877e208	chore: Refactor metastore Updater (breaking change) (#18821)	5 months ago
Robert Fratto	2ca8e58b0e	chore(dataobj): add ability to buffer pending sections to disk (#18780) ... Signed-off-by: Robert Fratto <robertfratto@gmail.com>	5 months ago