Use the correct row for the before field for debezium sources

ArroyoSystems · Dec 19, 2024 · 5c654ce · 5c654ce
1 parent e052d5a
commit 5c654ce
Show file tree

Hide file tree

Showing 3 changed files with 1,629 additions and 3,342 deletions.
diff --git a/crates/arroyo-planner/src/physical.rs b/crates/arroyo-planner/src/physical.rs
@@ -895,7 +895,7 @@ impl DebeziumUnrollingStream {
                     timestamp_builder.append_value(timestamp.value(i));
                 }
                 "u" => {
-                    take_indices.append_value((i + num_rows) as u32);
+                    take_indices.append_value(i as u32);
                     is_retract_builder.append_value(true);
                     timestamp_builder.append_value(timestamp.value(i));
                     take_indices.append_value((i + num_rows) as u32);