{"record":{"id":"32773dc80dff7876","repo":"risingwavelabs/risingwave","slug":"should-get-start-response-but-get-32773d","errorCode":null,"errorMessage":"should get start response but get {:?}","messagePattern":"should get start response but get (.+?)","errorType":"exception","errorClass":"anyhow::Error","httpStatus":null,"severity":"error","filePath":"src/rpc_client/src/sink_coordinate_client.rs","lineNumber":135,"sourceCode":"\n    pub async fn update_vnode_bitmap(&mut self, vnode_bitmap: &Bitmap) -> anyhow::Result<u64> {\n        self.send_request(CoordinateRequest {\n            msg: Some(coordinate_request::Msg::UpdateVnodeRequest(\n                UpdateVnodeBitmapRequest {\n                    vnode_bitmap: Some(vnode_bitmap.to_protobuf()),\n                },\n            )),\n        })\n        .await?;\n        match self.next_response().await? {\n            CoordinateResponse {\n                msg:\n                    Some(coordinate_response::Msg::StartResponse(StartCoordinationResponse {\n                        log_store_rewind_start_epoch,\n                    })),\n            } => Ok(log_store_rewind_start_epoch\n                .ok_or_else(|| anyhow!(\"should get start epoch after update vnode bitmap\"))?),\n            msg => Err(anyhow!(\"should get start response but get {:?}\", msg)),\n        }\n    }\n\n    pub async fn stop(mut self) -> anyhow::Result<()> {\n        self.send_request(CoordinateRequest {\n            msg: Some(coordinate_request::Msg::Stop(true)),\n        })\n        .await?;\n        match self.next_response().await? {\n            CoordinateResponse {\n                msg: Some(coordinate_response::Msg::Stopped(_)),\n            } => Ok(()),\n            msg => Err(anyhow!(\"should get Stopped but get {:?}\", msg)),\n        }\n    }\n\n    pub async fn align_initial_epoch(&mut self, initial_epoch: u64) -> anyhow::Result<u64> {\n        self.send_request(CoordinateRequest {","sourceCodeStart":117,"sourceCodeEnd":153,"githubUrl":"https://github.com/risingwavelabs/risingwave/blob/6469eb736d691e8e9b8a419a57edd6429ca77417/src/rpc_client/src/sink_coordinate_client.rs#L117-L153","documentation":"Same call as above: after sending UpdateVnodeRequest, SinkCoordinateClient::update_vnode_bitmap expects the next response to be a StartResponse. Any other CoordinateResponse variant triggers this error, indicating protocol desynchronization or a coordinator-side failure surfaced as a different message.","triggerScenarios":"Calling update_vnode_bitmap when the coordinator replies with something other than StartResponse — e.g. a response belonging to a stale request, coordinator restart mid-round, or mismatched protocol versions.","commonSituations":"Interleaved/misordered requests on the coordination stream; stream engine restarted during sink execution; upgrade skew between components.","solutions":["Read the debug-printed `msg` to see what the coordinator returned","Re-establish the sink coordination stream and retry from the failed epoch","Check coordinator logs for restarts/errors; align component versions"],"exampleFix":null,"handlingStrategy":"retry","validationCode":null,"typeGuard":null,"tryCatchPattern":"// Rust\nif let Err(e) = client.update_vnode_bitmap(&bitmap).await {\n    if e.to_string().contains(\"start response\") {\n        // desync: recreate stream and retry once\n        let mut c = SinkCoordinateClient::start(...).await?;\n        c.update_vnode_bitmap(&bitmap).await?;\n    } else { return Err(e); }\n}","preventionTips":["Never interleave requests on the coordination stream","Recreate the stream after any protocol error instead of reusing it","Verify protocol compatibility after upgrades"],"tags":["grpc","protocol","sink","streaming"],"backgroundTag":"unexpected-response-shape","analyzedSha":"6469eb736d691e8e9b8a419a57edd6429ca77417","analyzedAt":"2026-09-11T21:06:21.487Z","contentChangedAt":"2026-09-11T21:06:21.487Z","schemaVersion":2},"datasetVersion":"2026-09-14T16:17:12.679Z"}