fix state table from proto

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · May 6, 2023 · f18e572 · f18e572
1 parent b5608c3
commit f18e572
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/stream/src/from_proto/eowc_over_window.rs b/src/stream/src/from_proto/eowc_over_window.rs
@@ -56,7 +56,8 @@ impl ExecutorBuilder for EowcOverWindowExecutorBuilder {
                 .expect("vnodes not set for EOWC over window"),
         ));
         let state_table =
-            StateTable::from_table_catalog(node.get_state_table()?, store, vnodes).await;
+            StateTable::from_table_catalog_inconsistent_op(node.get_state_table()?, store, vnodes)
+                .await;
         Ok(EowcOverWindowExecutor::new(EowcOverWindowExecutorArgs {
             input,
             actor_ctx: params.actor_context,