pass streaming error score to meta to identify the global-root error

[BugenZhao]

We have a scoring mechanism to identify the root error that fails the streaming pipeline locally on each compute node.

risingwave/src/stream/src/task/barrier_manager.rs

Lines 887 to 894 in b51a40c

	/// Tries to find the root cause of actor failures, based on hard-coded rules.
	pub fn try_find_root_actor_failure<'a>(
	actor_errors: impl IntoIterator<Item = &'a StreamError>,
	) -> Option<StreamError> {
	// Explicitly list all error kinds here to notice developers to update this function when
	// there are changes in error kinds.
	fn stream_executor_error_score(e: &StreamExecutorError) -> i32 {

It would be better if we can pass the score to the meta service, so that it can find the global-root cause of the failure among all compute nodes, instead of concatenating all error messages.

risingwave/src/meta/src/barrier/rpc.rs

Lines 209 to 213 in b51a40c

	if let Some(command) = node.inflight_barriers.pop_front() {
	let errors = self.collect_errors(node.worker.id, err).await;
	let err = merge_node_rpc_errors("get error from control stream", errors);
	self.context.report_collect_failure(&command, &err);
	break Err(err);

To embed the score in gRPC error, one can make it a field of ServerError.

risingwave/src/error/src/tonic.rs

Lines 29 to 34 in b51a40c

	/// The error produced by the gRPC server and sent to the client on the wire.
	#[derive(Debug, Serialize, Deserialize)]
	struct ServerError {
	error: serde_error::Error,
	service_name: Option<ServiceName>,
	}