Function needThrowRootCauseError

src/Interpreters/executeQuery.cpp:332–355

}

bool needThrowRootCauseError(const Context * context, int & error_code, String & error_messge)
{
    const String & query_id = context->getCurrentQueryId();
    auto coordinator = MPPQueryManager::instance().getCoordinator(query_id);
    if (!coordinator)
        return false;

    if (coordinator->getContext().get() != context)
        return false;

    coordinator->updateSegmentInstanceStatus(RuntimeSegmentsStatus{
        .query_id = query_id, .segment_id = 0, .is_succeed = false, .message = error_messge, .code = error_code});
    if (isAmbiguosError(error_code))
    {
        auto query_status = coordinator->waitUntilFinish(error_code, error_messge);
        if (query_status.error_code != error_code)
        {
            error_code = query_status.error_code;
            error_messge = query_status.summarized_error_msg;
            return true;
        }
    }
    return false;
}

static void checkASTSizeLimits(const IAST & ast, const Settings & settings)
{