From 8e926e297cb435cb838d1858fb8d311848dad8e2 Mon Sep 17 00:00:00 2001 From: xxchan Date: Thu, 12 Dec 2024 22:00:49 +0800 Subject: [PATCH] ok --- ci/plugins/upload-failure-logs/hooks/post-command | 2 +- ci/scripts/build-simulation.sh | 2 -- ci/scripts/run-e2e-test.sh | 2 -- src/meta/src/manager/diagnose.rs | 3 +-- 4 files changed, 2 insertions(+), 7 deletions(-) diff --git a/ci/plugins/upload-failure-logs/hooks/post-command b/ci/plugins/upload-failure-logs/hooks/post-command index a09f8ad202a0d..a0cd360c1c575 100755 --- a/ci/plugins/upload-failure-logs/hooks/post-command +++ b/ci/plugins/upload-failure-logs/hooks/post-command @@ -17,4 +17,4 @@ if [ $BUILDKITE_COMMAND_EXIT_STATUS -ne 0 ]; then if [ -e "$PWD/connector-node.log" ]; then buildkite-agent artifact upload "$PWD/connector-node.log" fi -fi +fi \ No newline at end of file diff --git a/ci/scripts/build-simulation.sh b/ci/scripts/build-simulation.sh index e378511d1359a..7d8f09c5ca923 100755 --- a/ci/scripts/build-simulation.sh +++ b/ci/scripts/build-simulation.sh @@ -5,8 +5,6 @@ set -euo pipefail source ci/scripts/common.sh -exit 88 - echo "--- Generate RiseDev CI config" cp ci/risedev-components.ci.env risedev-components.user.env diff --git a/ci/scripts/run-e2e-test.sh b/ci/scripts/run-e2e-test.sh index 75ea53def1e02..02268a7e1c873 100755 --- a/ci/scripts/run-e2e-test.sh +++ b/ci/scripts/run-e2e-test.sh @@ -82,8 +82,6 @@ echo "--- e2e, $mode, streaming" RUST_LOG="info,risingwave_stream=info,risingwave_batch=info,risingwave_storage=info,risingwave_stream::common::table::state_table=warn" \ cluster_start -exit 88 - # Please make sure the regression is expected before increasing the timeout. sqllogictest -p 4566 -d dev './e2e_test/streaming/**/*.slt' --junit "streaming-${profile}" sqllogictest -p 4566 -d dev './e2e_test/backfill/sink/different_pk_and_dist_key.slt' diff --git a/src/meta/src/manager/diagnose.rs b/src/meta/src/manager/diagnose.rs index 2c07ab38dda76..062483374aa31 100644 --- a/src/meta/src/manager/diagnose.rs +++ b/src/meta/src/manager/diagnose.rs @@ -171,8 +171,7 @@ impl DiagnoseCommand { &mut row, worker_node.get_state().ok().map(|s| s.as_str_name()), ); - // FIXME: - // row.add_cell(worker_node.parallelism().into()); + row.add_cell(worker_node.parallelism().into()); try_add_cell( &mut row, worker_node.property.as_ref().map(|p| p.is_streaming),