Skip to content

Commit

Permalink
feat(meta): recover stream job progress (#12167)
Browse files Browse the repository at this point in the history
Co-authored-by: August <[email protected]>
  • Loading branch information
kwannoel and yezizp2012 authored Oct 21, 2023
1 parent ccef1c5 commit 6833305
Show file tree
Hide file tree
Showing 40 changed files with 1,546 additions and 211 deletions.
1 change: 0 additions & 1 deletion Makefile.toml
Original file line number Diff line number Diff line change
Expand Up @@ -1317,7 +1317,6 @@ dependencies = ["k", "l", "check-logs", "wait-processes-exit"]
description = "Kill cluster, dump logs and check logs"

[tasks.wait-processes-exit]
private = true
category = "Misc"
description = "Wait for RisingWave processes to exit"
script = """
Expand Down
10 changes: 9 additions & 1 deletion ci/scripts/deterministic-recovery-test.sh
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,19 @@ echo "--- Download artifacts"
download-and-decompress-artifact risingwave_simulation .
chmod +x ./risingwave_simulation

export RUST_LOG="info,risingwave_meta::barrier::recovery=debug"
export RUST_LOG="info,\
risingwave_meta::barrier::recovery=debug,\
risingwave_meta::rpc::ddl_controller=debug,\
risingwave_meta::barrier::mod=debug,\
risingwave_simulation=debug"
export LOGDIR=.risingwave/log

mkdir -p $LOGDIR

# FIXME(kwannoel): Why is this failing?
# echo "--- deterministic simulation e2e, ci-3cn-2fe-3meta, recovery, background_ddl"
# seq $TEST_NUM | parallel MADSIM_TEST_SEED={} './risingwave_simulation --kill --kill-rate=${KILL_RATE} ./e2e_test/background_ddl/sim/basic.slt 2> $LOGDIR/recovery-ddl-{}.log && rm $LOGDIR/recovery-ddl-{}.log'

echo "--- deterministic simulation e2e, ci-3cn-2fe-3meta, recovery, ddl"
seq $TEST_NUM | parallel MADSIM_TEST_SEED={} './risingwave_simulation --kill --kill-rate=${KILL_RATE} ./e2e_test/ddl/\*\*/\*.slt 2> $LOGDIR/recovery-ddl-{}.log && rm $LOGDIR/recovery-ddl-{}.log'

Expand Down
Loading

0 comments on commit 6833305

Please sign in to comment.