From 8283cd29deb15546412834613822597bd0928c7c Mon Sep 17 00:00:00 2001 From: Patrick Huang Date: Thu, 17 Oct 2024 13:43:51 +0800 Subject: [PATCH] remove unneccessary changes --- .../tests/integration_tests/sink/err_isolation.rs | 6 ------ 1 file changed, 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 index e3e004978ca33..124653946b872 100644 --- 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);