From 7fc74e2928a5162ad6fa1d832c2b550aa49f3701 Mon Sep 17 00:00:00 2001
From: "Lei, HUANG" <mrsatangel@gmail.com>
Date: Wed, 11 Jun 2025 08:09:26 +0000
Subject: [PATCH] feat/bulk-support-flow-batch:  ## Update
 `handle_mark_window_dirty` Method in `flownode_impl.rs`

 - Replaced `unimplemented!()` with `unreachable!()` in the `handle_mark_window_dirty` method for both `FlowDualEngine` and `StreamingEngine` implementations in `flownode_impl.rs`.

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>
---
 src/flow/src/adapter/flownode_impl.rs | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/flow/src/adapter/flownode_impl.rs b/src/flow/src/adapter/flownode_impl.rs
index eba72c26e9..00e5c8157d 100644
--- a/src/flow/src/adapter/flownode_impl.rs
+++ b/src/flow/src/adapter/flownode_impl.rs
@@ -835,8 +835,7 @@ impl common_meta::node_manager::Flownode for FlowDualEngine {
     }
 
     async fn handle_mark_window_dirty(&self, _req: DirtyWindowRequest) -> MetaResult<FlowResponse> {
-        // todo: implement
-        unimplemented!()
+        unreachable!()
     }
 }
 
@@ -947,8 +946,7 @@ impl common_meta::node_manager::Flownode for StreamingEngine {
     }
 
     async fn handle_mark_window_dirty(&self, _req: DirtyWindowRequest) -> MetaResult<FlowResponse> {
-        // todo: implement
-        unimplemented!()
+        unreachable!()
     }
 }