diff --git a/src/operator/join/local_sort_merge.rs b/src/operator/join/local_sort_merge.rs index 89a28ab..1b3de00 100644 --- a/src/operator/join/local_sort_merge.rs +++ b/src/operator/join/local_sort_merge.rs @@ -187,11 +187,11 @@ impl< } StreamElement::Item(BinaryElement::LeftEnd) => { self.left_ended = true; - self.left.sort_unstable_by(|(k1, _), (k2, _)| k1.cmp(k2)); + glidesort::sort_by(&mut self.left, |(k1, _), (k2, _)| k1.cmp(k2)); } StreamElement::Item(BinaryElement::RightEnd) => { self.right_ended = true; - self.right.sort_unstable_by(|(k1, _), (k2, _)| k1.cmp(k2)); + glidesort::sort_by(&mut self.right, |(k1, _), (k2, _)| k1.cmp(k2)); } StreamElement::Timestamped(_, _) | StreamElement::Watermark(_) => { panic!("Cannot join timestamp streams")