| 516 | } |
| 517 | |
| 518 | Status CatalogOpExecutor::WaitForHmsEvent(const TWaitForHmsEventRequest& req, |
| 519 | TWaitForHmsEventResponse* resp) { |
| 520 | int attempt = 0; // Used for debug action only. |
| 521 | MonotonicStopWatch sw; |
| 522 | sw.Start(); |
| 523 | CatalogServiceConnection::RpcStatus rpc_status = |
| 524 | CatalogServiceConnection::DoRpcWithRetry(env_->catalogd_client_cache(), |
| 525 | *ExecEnv::GetInstance()->GetCatalogdAddress().get(), |
| 526 | &CatalogServiceClientWrapper::WaitForHmsEvent, req, |
| 527 | FLAGS_catalog_client_connection_num_retries, |
| 528 | FLAGS_catalog_client_rpc_retry_interval_ms, |
| 529 | [&attempt]() { return CatalogRpcDebugFn(&attempt); }, resp); |
| 530 | RETURN_IF_ERROR(rpc_status.status); |
| 531 | ImpaladMetrics::WAIT_FOR_HMS_EVENT_DURATIONS->Update( |
| 532 | sw.ElapsedTime() / NANOS_PER_MICRO / MICROS_PER_MILLI); |
| 533 | return StatusFromThrift(resp->status); |
| 534 | } |
nothing calls this directly
no test coverage detected