fix: add assertion to check stream executor schema consistency (#13288)

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Nov 16, 2023 · 04aca78 · 04aca78
1 parent 4e16834
commit 04aca78
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/stream/src/task/stream_manager.rs b/src/stream/src/task/stream_manager.rs
@@ -583,6 +583,12 @@ impl LocalStreamManagerCore {
             "`pk_indices` of {} not consistent with what derived by optimizer",
             executor.identity()
         );
+        assert_eq!(
+            executor.schema(),
+            &schema,
+            "`schema` of {} not consistent with what derived by optimizer",
+            executor.identity()
+        );
 
         // Wrap the executor for debug purpose.
         let executor = WrapperExecutor::new(