From 34f42370b6950b8262d8260778c0fd6334f5d386 Mon Sep 17 00:00:00 2001 From: William Wen Date: Tue, 6 Aug 2024 16:50:13 +0800 Subject: [PATCH] add logs --- ci/scripts/run-backfill-tests.sh | 38 +++++++++++++------------- src/stream/src/task/barrier_manager.rs | 2 +- 2 files changed, 20 insertions(+), 20 deletions(-) diff --git a/ci/scripts/run-backfill-tests.sh b/ci/scripts/run-backfill-tests.sh index 917c67b6958a8..83ce5b2692a7e 100755 --- a/ci/scripts/run-backfill-tests.sh +++ b/ci/scripts/run-backfill-tests.sh @@ -300,28 +300,28 @@ test_snapshot_backfill() { main() { set -euo pipefail - test_snapshot_and_upstream_read - test_backfill_tombstone - test_replication_with_column_pruning - test_sink_backfill_recovery +# test_snapshot_and_upstream_read +# test_backfill_tombstone +# test_replication_with_column_pruning +# test_sink_backfill_recovery test_snapshot_backfill # Only if profile is "ci-release", run it. - if [[ ${profile:-} == "ci-release" ]]; then - echo "--- Using release profile, running backfill performance tests." - # Need separate tests, we don't want to backfill concurrently. - # It's difficult to measure the time taken for each backfill if we do so. - test_no_shuffle_backfill_snapshot_and_upstream_runtime - test_arrangement_backfill_snapshot_and_upstream_runtime - - # Backfill will happen in sequence here. - test_backfill_snapshot_runtime - test_backfill_snapshot_with_wider_rows - test_backfill_snapshot_with_limited_storage_throughput - - # No upstream only tests, because if there's no snapshot, - # Backfill will complete almost immediately. - fi +# if [[ ${profile:-} == "ci-release" ]]; then +# echo "--- Using release profile, running backfill performance tests." +# # Need separate tests, we don't want to backfill concurrently. +# # It's difficult to measure the time taken for each backfill if we do so. +# test_no_shuffle_backfill_snapshot_and_upstream_runtime +# test_arrangement_backfill_snapshot_and_upstream_runtime +# +# # Backfill will happen in sequence here. +# test_backfill_snapshot_runtime +# test_backfill_snapshot_with_wider_rows +# test_backfill_snapshot_with_limited_storage_throughput +# +# # No upstream only tests, because if there's no snapshot, +# # Backfill will complete almost immediately. +# fi } main diff --git a/src/stream/src/task/barrier_manager.rs b/src/stream/src/task/barrier_manager.rs index 28bb450d3c07d..7bc5d9b8d5f5b 100644 --- a/src/stream/src/task/barrier_manager.rs +++ b/src/stream/src/task/barrier_manager.rs @@ -832,7 +832,7 @@ impl LocalBarrierWorker { // Actors to stop should still accept this barrier, but won't get sent to in next times. if let Some(actors) = barrier.all_stop_actors() { - debug!( + error!( target: "events::stream::barrier::manager", "remove actors {:?} from senders", actors