From 521d683a041a39a5941901e63c9302a8f3af1afd Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Mon, 15 May 2023 23:17:42 +0800 Subject: [PATCH] fix --- src/stream/src/executor/backfill.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/stream/src/executor/backfill.rs b/src/stream/src/executor/backfill.rs index 13e858bc89b7c..fe48f9015e4fe 100644 --- a/src/stream/src/executor/backfill.rs +++ b/src/stream/src/executor/backfill.rs @@ -209,7 +209,7 @@ where let left_upstream = upstream.by_ref().map(Either::Left); let right_snapshot = pin!(Self::snapshot_read( - &self.upstreamtable, + &self.upstream_table, snapshot_read_epoch, current_pos.clone(), true