fix: update indexing service fingerprint constants and nightly fmt

Adding ParquetMergePolicyConfig and ParquetIndexingConfig to
IndexingSettings changes the Hash output, which changes the pipeline
params fingerprints. Updated the hardcoded test constants.

Added a comment explaining how to recompute them when IndexingSettings
fields change.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: g-talbot

quickwit/quickwit-config/Cargo.toml

@@ -45,5 +45,6 @@ quickwit-common = { workspace = true, features = ["testsuite"] }
 quickwit-proto = { workspace = true, features = ["testsuite"] }
 
 [features]
+metrics = []
 testsuite = []
 vrl = ["dep:vrl"]

quickwit/quickwit-config/src/index_config/mod.rs

@@ -118,15 +118,14 @@ pub struct IndexingSettings {
     pub split_num_docs_target: usize,
     #[serde(default)]
     pub merge_policy: MergePolicyConfig,
-    /// Merge policy for Parquet (metrics/sketches) splits. Controls how
-    /// Parquet splits are compacted within time windows. Only used by
-    /// indexes that use the Parquet indexing pipeline.
-    #[serde(default)]
-    pub parquet_merge_policy: ParquetMergePolicyConfig,
-    /// Parquet-specific indexing settings (sort schema, window duration,
-    /// compression). Only used by indexes that use the Parquet pipeline.
-    #[serde(default)]
-    pub parquet_indexing: ParquetIndexingConfig,
+    /// Merge policy for Parquet (metrics/sketches) splits.
+    #[cfg(feature = "metrics")]
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub parquet_merge_policy: Option<ParquetMergePolicyConfig>,
+    /// Parquet-specific indexing settings (sort schema, window duration).
+    #[cfg(feature = "metrics")]
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub parquet_indexing: Option<ParquetIndexingConfig>,
     #[serde(default)]
     pub resources: IndexingResources,
 }
@@ -147,12 +146,11 @@ pub struct ParquetIndexingConfig {
     /// (`__s` = string, `__i` = int64, `_secs` = uint64 timestamp).
     ///
     /// The sort order determines:
-    /// - **Query pruning**: queries that filter on leading sort columns can
-    ///   skip entire splits whose row key ranges don't match.
-    /// - **Compression**: columns with good locality (e.g., metric_name first)
-    ///   compress better in Parquet's columnar format.
-    /// - **Compaction scope**: splits with different sort schemas are never
-    ///   merged together.
+    /// - **Query pruning**: queries that filter on leading sort columns can skip entire splits
+    ///   whose row key ranges don't match.
+    /// - **Compression**: columns with good locality (e.g., metric_name first) compress better in
+    ///   Parquet's columnar format.
+    /// - **Compaction scope**: splits with different sort schemas are never merged together.
     ///
     /// When `None`, the product-type default is used (see below).
     ///
@@ -208,6 +206,20 @@ impl IndexingSettings {
         Duration::from_secs(self.commit_timeout_secs as u64)
     }
 
+    /// Returns the Parquet merge policy config, using defaults if not
+    /// explicitly configured.
+    #[cfg(feature = "metrics")]
+    pub fn parquet_merge_policy(&self) -> ParquetMergePolicyConfig {
+        self.parquet_merge_policy.clone().unwrap_or_default()
+    }
+
+    /// Returns the Parquet indexing config, using defaults if not
+    /// explicitly configured.
+    #[cfg(feature = "metrics")]
+    pub fn parquet_indexing(&self) -> ParquetIndexingConfig {
+        self.parquet_indexing.clone().unwrap_or_default()
+    }
+
     fn default_commit_timeout_secs() -> usize {
         60
     }
@@ -241,8 +253,10 @@ impl Default for IndexingSettings {
             docstore_compression_level: Self::default_docstore_compression_level(),
             split_num_docs_target: Self::default_split_num_docs_target(),
             merge_policy: MergePolicyConfig::default(),
-            parquet_merge_policy: ParquetMergePolicyConfig::default(),
-            parquet_indexing: ParquetIndexingConfig::default(),
+            #[cfg(feature = "metrics")]
+            parquet_merge_policy: None,
+            #[cfg(feature = "metrics")]
+            parquet_indexing: None,
             resources: IndexingResources::default(),
         }
     }

quickwit/quickwit-config/src/merge_policy_config.rs

@@ -120,6 +120,10 @@ impl Default for StableLogMergePolicyConfig {
 }
 
 // --- Parquet merge policy config ---
+//
+// The types are always available (for OpenAPI schema generation in
+// quickwit-serve). The IndexingSettings fields that use them are
+// gated behind cfg(feature = "metrics").
 
 fn default_target_split_size_bytes() -> u64 {
     256 * 1024 * 1024 // 256 MiB

quickwit/quickwit-indexing/Cargo.toml

@@ -105,7 +105,7 @@ testsuite = [
   "quickwit-proto/testsuite",
   "quickwit-storage/testsuite"
 ]
-metrics = ["dep:arrow", "dep:quickwit-parquet-engine", "quickwit-doc-mapper/metrics"]
+metrics = ["dep:arrow", "dep:quickwit-parquet-engine", "quickwit-doc-mapper/metrics", "quickwit-config/metrics"]
 vrl = ["dep:vrl", "quickwit-config/vrl"]
 postgres = ["quickwit-metastore/postgres"]
 ci-test = []

quickwit/quickwit-indexing/src/actors/indexing_service.rs

@@ -1250,9 +1250,13 @@ mod tests {
 
     #[tokio::test]
     async fn test_indexing_service_apply_plan() {
-        const PARAMS_FINGERPRINT_INGEST_API: u64 = 1637744865450232394;
-        const PARAMS_FINGERPRINT_SOURCE_1: u64 = 1705211905504908791;
-        const PARAMS_FINGERPRINT_SOURCE_2: u64 = 8706667372658059428;
+        // These fingerprints are hashes of IndexConfig + SourceConfig. They
+        // change whenever IndexingSettings fields are added/removed. Recompute
+        // by temporarily adding a test that prints
+        // `indexing_pipeline_params_fingerprint(&index_config, &source_config)`.
+        const PARAMS_FINGERPRINT_INGEST_API: u64 = 7973087274884969148;
+        const PARAMS_FINGERPRINT_SOURCE_1: u64 = 9420938500552890840;
+        const PARAMS_FINGERPRINT_SOURCE_2: u64 = 16199199787360162635;
 
         quickwit_common::setup_logging_for_tests();
         let transport = ChannelTransport::default();