risingwavelabs/risingwave · error · SinkError

Can't get doris BE url

Error message

Can't get doris BE url

What it means

try_get_be_url maps a successful 200 response to Ok(None) (transactional APIs answered by the FE directly). Any other status code that is not 307/200 falls through to this catch-all error, meaning the FE replied with an unexpected HTTP status and no BE URL can be extracted.

Source

Thrown at src/connector/src/sink/doris_starrocks_connector.rs:223

                })?;

                if be_host == LOCALHOST || be_host == LOCALHOST_IP {
                    // if be host is 127.0.0.1, we may can't connect to it directly,
                    // so replace it with fe host
                    parsed_be_url
                        .set_host(Some(fe_host))
                        .map_err(|err| SinkError::DorisStarrocksConnect(anyhow!(err)))?;
                }
            }
            Ok(Some(parsed_be_url))
        }
        StatusCode::OK => {
            // Some of the `StarRocks` transactional APIs will respond directly from FE. For example,
            // the request to `/api/transaction/commit` endpoint does not seem to redirect to BE.
            // In this case, the request should be treated as finished.
            Ok(None)
        }
        _ => Err(SinkError::DorisStarrocksConnect(anyhow!(
            "Can't get doris BE url",
        ))),
    }
}

pub struct InserterInnerBuilder {
    url: String,
    header: HashMap<String, String>,
    #[expect(dead_code)]
    sender: Option<Sender>,
    fe_host: String,
    stream_load_http_timeout: Duration,
}
impl InserterInnerBuilder {
    pub fn new(
        url: String,
        db: String,
        table: String,

View on GitHub (pinned to 6469eb736d)

Solutions

1. Log the actual response status/body to identify whether it is auth (401), routing (404), or server (5xx).
2. Verify the Doris sink username, password, database, and table options.
3. Check Doris FE health and logs for server-side errors.
4. Confirm the Doris version is compatible with the connector endpoints.

match try_get_be_url(resp).await {
    Err(SinkError::DorisStarrocksConnect(e)) if e.to_string().contains("Can't get doris BE url") => {
        // inspect status: retry on 5xx, fix credentials/route on 401/404
        eprintln!("unexpected FE status: {e}");
    }
    other => other?,
}

When it happens

Trigger: Receiving an HTTP status other than 200 or 307 (e.g. 401 Unauthorized, 404 Not Found, 500 Internal Server Error, 502) from the Doris FE during stream load or transaction calls.

Common situations: Wrong user/password in the sink options (401); wrong database/table path (404); Doris FE crashed or overloaded (500/502); version-incompatible endpoints.

Related errors

• Can't find data
• Insert error: {:?}, error url: {:?}
• Can't get doris BE url in header
• Can't get be host from url
• `{}` must be {}, or {}

AI-assisted analysis of risingwavelabs/risingwave@6469eb736d (2026-09-11). Data as JSON: /api/errors/7ab8086346db21b2. Report an issue: GitHub.