debug

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Apr 8, 2024 · bfffd6a · bfffd6a
1 parent f68bb80
commit bfffd6a
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 9 deletions.
diff --git a/src/stream/src/executor/dispatch.rs b/src/stream/src/executor/dispatch.rs
@@ -349,13 +349,13 @@ impl DispatchExecutor {
         metrics: Arc<StreamingMetrics>,
         chunk_size: usize,
     ) -> Self {
-        // if crate::consistency::insane() {
-        //     // make some trouble before dispatching to avoid generating invalid dist key.
-        //     let mut info = input.info().clone();
-        //     info.identity = format!("{} (embedded trouble)", info.identity);
-        //     let troublemaker = TroublemakerExecutor::new(input, chunk_size);
-        //     input = (info, troublemaker).into();
-        // }
+        if false && crate::consistency::insane() {
+            // make some trouble before dispatching to avoid generating invalid dist key.
+            let mut info = input.info().clone();
+            info.identity = format!("{} (embedded trouble)", info.identity);
+            let troublemaker = TroublemakerExecutor::new(input, chunk_size);
+            input = (info, troublemaker).into();
+        }
 
         let actor_id_str = actor_id.to_string();
         let fragment_id_str = fragment_id.to_string();

diff --git a/src/stream/src/executor/troublemaker.rs b/src/stream/src/executor/troublemaker.rs
@@ -49,7 +49,10 @@ struct Vars {
 impl TroublemakerExecutor {
     pub fn new(input: Executor, chunk_size: usize) -> Self {
         assert!(insane(), "we should only make trouble in insane mode");
-        tracing::info!("we got a troublemaker");
+        tracing::info!(
+            "we got a troublemaker following executor {:?}",
+            input.info()
+        );
         Self {
             input,
             inner: Inner { chunk_size },

diff --git a/src/stream/src/from_proto/stream_scan.rs b/src/stream/src/from_proto/stream_scan.rs
@@ -154,7 +154,7 @@ impl ExecutorBuilder for StreamScanExecutorBuilder {
             node.rate_limit.map(|x| x as _),
         );
 
-        if crate::consistency::insane() {
+        if false && crate::consistency::insane() {
             let mut info = params.info.clone();
             info.identity = format!("{} (troubled)", info.identity);
             Ok((