From a80dc6a4d15343a1135b75d5b1253a4e67fe7b98 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Tue, 31 Oct 2023 18:28:34 +0800 Subject: [PATCH 1/2] revert no-capture --- ci/scripts/deterministic-it-test.sh | 1 - 1 file changed, 1 deletion(-) diff --git a/ci/scripts/deterministic-it-test.sh b/ci/scripts/deterministic-it-test.sh index 5d76a6677d580..f281eaa467bfd 100755 --- a/ci/scripts/deterministic-it-test.sh +++ b/ci/scripts/deterministic-it-test.sh @@ -16,7 +16,6 @@ mv target/ci-sim target/sim echo "--- Run integration tests in deterministic simulation mode" seq $TEST_NUM | parallel MADSIM_TEST_SEED={} NEXTEST_PROFILE=ci-sim \ cargo nextest run \ - --no-capture \ --no-fail-fast \ --cargo-metadata target/nextest/cargo-metadata.json \ --binaries-metadata target/nextest/binaries-metadata.json \ From 28b4d4df6b3a05c5e1579154aaf434e2a04eb735 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Wed, 1 Nov 2023 00:13:29 +0800 Subject: [PATCH 2/2] try throttle test source --- src/tests/simulation/tests/integration_tests/sink/basic.rs | 4 ++-- src/tests/simulation/tests/integration_tests/sink/recovery.rs | 2 +- src/tests/simulation/tests/integration_tests/sink/scale.rs | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/tests/simulation/tests/integration_tests/sink/basic.rs b/src/tests/simulation/tests/integration_tests/sink/basic.rs index 24f709139f0fc..d81563babe2e7 100644 --- 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 index c23ea7fe5fa78..667af61c1c780 100644 --- 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 index 259678636d535..19b3368a724d2 100644 --- 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();