Skip to content

Commit 5575340

Browse files
committed
reactor: change state key for max load keys
Updates the key that's used within materialization state to track the max key that's been observed. We had temporarily disabled the load key optimizations as part of the 0325 indcident recovery, and this effectively makes that disablement permanent for existing tasks, while allowing it to be used for any newly created tasks.
1 parent 13c38d5 commit 5575340

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

Diff for: crates/runtime/src/materialize/protocol.rs

+6-1
Original file line numberDiff line numberDiff line change
@@ -586,5 +586,10 @@ pub async fn recv_connector_started_commit(
586586
}
587587

588588
fn max_key_key(binding: &Binding) -> String {
589-
format!("MK:{}", &binding.state_key)
589+
// Key name changed in order to effectively disable the load optimization
590+
// for all existing materializations, while preserving it for any new ones.
591+
// The optimization was temporarily disabled as part of the 0325 incident
592+
// recovery, and this effectively makes that permanent, while allowing it to
593+
// be used on new tasks.
594+
format!("MK-v2:{}", &binding.state_key)
590595
}

0 commit comments

Comments
 (0)