Skip to content

Conversation

@msrathore-db
Copy link
Collaborator

@msrathore-db msrathore-db commented Nov 17, 2025

🥞 Stacked PR

Use this link to review incremental changes.


Summary

Adds configuration foundation for straggler mitigation in CloudFetch. Introduces configuration parameters and parsing/validation logic without behavioral changes.

Configuration Parameters:

  • adbc.databricks.cloudfetch.straggler_mitigation_enabled (default: false)
  • adbc.databricks.cloudfetch.straggler_multiplier (default: 1.5)
  • adbc.databricks.cloudfetch.straggler_quantile (default: 0.6)
  • adbc.databricks.cloudfetch.straggler_padding_seconds (default: 5)
  • adbc.databricks.cloudfetch.max_stragglers_per_query (default: 10)
  • adbc.databricks.cloudfetch.synchronous_fallback_enabled (default: true)

Key Changes:

  • DatabricksParameters constants for all configuration options
  • CloudFetchStragglerMitigationConfig class with parsing and validation
  • ✅ Parameter range validation with clear error messages
  • ✅ Immutable configuration object with default values

- Add configuration parameters in DatabricksParameters for straggler mitigation
- Implement CloudFetchStragglerMitigationConfig for parsing and validation
- Support 6 configuration options: enabled flag, multiplier, quantile, padding, max stragglers, fallback flag
- Validate parameter ranges with clear error messages
- Default values: disabled by default, 1.5x multiplier, 60% quantile, 5s padding

Part of stacked PR for straggler download mitigation feature
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants