From 04aca78fcb5b843e82a0e0b0e6928dd5fac3a0c8 Mon Sep 17 00:00:00 2001
From: Richard Chien <stdrc@outlook.com>
Date: Thu, 16 Nov 2023 13:13:38 +0800
Subject: [PATCH] fix: add assertion to check stream executor schema
 consistency (#13288)

Signed-off-by: Richard Chien <stdrc@outlook.com>
---
 src/stream/src/task/stream_manager.rs | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/stream/src/task/stream_manager.rs b/src/stream/src/task/stream_manager.rs
index 22a99c2099b5a..35ebb2581dc40 100644
--- 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(