address comment

risingwavelabs · Mar 23, 2023 · bb6c07c · bb6c07c
1 parent fe3ef50
commit bb6c07c
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/src/stream/src/common/table/state_table.rs b/src/stream/src/common/table/state_table.rs
@@ -815,12 +815,10 @@ where
             )
         });
         if let Some(watermark_suffix) = watermark_suffix {
-            let range_begin_suffix =
-                if prefix_serializer.unwrap().get_order_types()[0].nulls_are_largest() {
-                    vec![]
-                } else {
-                    vec![1u8]
-                };
+            let range_begin_suffix = watermark_suffix
+                .first()
+                .map(|bit| vec![*bit])
+                .unwrap_or_default();
             trace!(table_id = %self.table_id, watermark = ?watermark_suffix, vnodes = ?{
                 self.vnodes.iter_vnodes().collect_vec()
             }, "delete range");