Merge branch 'kwannoel/debug-deterministic-test' into kwannoel/use-ra…

…te-limit
risingwavelabs · Oct 31, 2023 · f427a27 · f427a27
2 parents 5c9513b + 28b4d4d
commit f427a27
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/tests/simulation/tests/integration_tests/sink/basic.rs b/src/tests/simulation/tests/integration_tests/sink/basic.rs
@@ -29,7 +29,7 @@ async fn basic_test_inner(is_decouple: bool) -> Result<()> {
     let mut cluster = start_sink_test_cluster().await?;
 
     let test_sink = SimulationTestSink::register_new();
-    let test_source = SimulationTestSource::register_new(12, 0..500000, 0.2, 50);
+    let test_source = SimulationTestSource::register_new(6, 0..100000, 0.2, 20);
 
     let mut session = cluster.start_session();
 
@@ -72,7 +72,7 @@ async fn test_sink_decouple_basic() -> Result<()> {
 async fn test_sink_decouple_blackhole() -> Result<()> {
     let mut cluster = start_sink_test_cluster().await?;
 
-    let test_source = SimulationTestSource::register_new(12, 0..500000, 0.2, 50);
+    let test_source = SimulationTestSource::register_new(6, 0..100000, 0.2, 20);
 
     let mut session = cluster.start_session();
 

diff --git a/src/tests/simulation/tests/integration_tests/sink/recovery.rs b/src/tests/simulation/tests/integration_tests/sink/recovery.rs
@@ -57,7 +57,7 @@ async fn recovery_test_inner(is_decouple: bool) -> Result<()> {
     let mut cluster = start_sink_test_cluster().await?;
 
     let test_sink = SimulationTestSink::register_new();
-    let test_source = SimulationTestSource::register_new(12, 0..500000, 0.2, 50);
+    let test_source = SimulationTestSource::register_new(6, 0..100000, 0.2, 20);
 
     let mut session = cluster.start_session();
 

diff --git a/src/tests/simulation/tests/integration_tests/sink/scale.rs b/src/tests/simulation/tests/integration_tests/sink/scale.rs
@@ -58,7 +58,7 @@ async fn scale_test_inner(is_decouple: bool) -> Result<()> {
     let mut cluster = start_sink_test_cluster().await?;
 
     let test_sink = SimulationTestSink::register_new();
-    let test_source = SimulationTestSource::register_new(12, 0..500000, 0.2, 20);
+    let test_source = SimulationTestSource::register_new(6, 0..100000, 0.2, 20);
 
     let mut session = cluster.start_session();