remove unneccessary changes

risingwavelabs · Oct 17, 2024 · 8283cd2 · 8283cd2
1 parent b3819c7
commit 8283cd2
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/src/tests/simulation/tests/integration_tests/sink/err_isolation.rs b/src/tests/simulation/tests/integration_tests/sink/err_isolation.rs
@@ -58,12 +58,6 @@ async fn test_sink_decouple_err_isolation() -> Result<()> {
         test_source.create_stream_count.load(Relaxed)
     );
 
-    let result = session
-        .run("select * from rw_event_logs where event_type = 'SINK_FAIL'")
-        .await?;
-    assert!(!result.is_empty());
-    println!("Sink fail event: {:?}", result);
-
     assert_eq!(0, test_sink.parallelism_counter.load(Relaxed));
     test_sink.store.check_simple_result(&test_source.id_list)?;
     assert!(test_sink.store.inner().checkpoint_count > 0);