Helper method to forward cluster membership updates to the frontend. For additional details see comments for PopulateExecutorMembershipRequest() in cluster-membership-mgr.cc
| 210 | /// For additional details see comments for PopulateExecutorMembershipRequest() |
| 211 | /// in cluster-membership-mgr.cc |
| 212 | void SendClusterMembershipToFrontend(const ClusterMembershipMgr::SnapshotPtr& snapshot, |
| 213 | const vector<TExecutorGroupSet>& expected_exec_group_sets, Frontend* frontend) { |
| 214 | TUpdateExecutorMembershipRequest update_req; |
| 215 | |
| 216 | PopulateExecutorMembershipRequest(snapshot, expected_exec_group_sets, update_req); |
| 217 | |
| 218 | Status status = frontend->UpdateExecutorMembership(update_req); |
| 219 | if (!status.ok()) { |
| 220 | LOG(WARNING) << "Error updating frontend membership snapshot: " << status.GetDetail(); |
| 221 | } |
| 222 | } |
| 223 | } |
| 224 | |
| 225 | namespace impala { |
no test coverage detected