Skip to content

Fix HiveToDruid operator and jobs using snapshot

Joal requested to merge fix_snapshot_druid_loading into main

The operator was indexing only the latest month of the snapshot, not the full snapshot. This patch adds an explicit parameter to the HiveToDruid operator, telling the HiveToDruid scala job to use the same parameter, which uses an explicit snapshot value instead of relying on druid indexation boundaries.

Merge request reports