ok

Author: xxchan

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

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
 

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'

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),