diff --git a/src/flow/src/expr/relation/func.rs b/src/flow/src/expr/relation/func.rs index af6c72c6b52c..afcdb7ddd152 100644 --- a/src/flow/src/expr/relation/func.rs +++ b/src/flow/src/expr/relation/func.rs @@ -210,6 +210,7 @@ impl std::iter::Iterator for VectorDiffIter { return None; } let value = self.vector.get(self.idx); + // +1 means insert, -1 means delete, and default to +1 insert when diff is not provided let diff = if let Some(diff) = self.diff.as_ref() { if let Ok(diff_at) = diff.get(self.idx).try_into() { diff_at