Searched refs:masterEndpoints (Results 1 – 1 of 1) sorted by relevance
43 masterEndpoints: Seq[RpcEndpointRef],109 for (masterEndpoint <- masterEndpoints) {179 if (lostMasters.size >= masterEndpoints.size) {191 if (lostMasters.size >= masterEndpoints.size) {232 val masterEndpoints = driverArgs.masters.map(RpcAddress.fromSparkURL). constant234 rpcEnv.setupEndpoint("client", new ClientEndpoint(rpcEnv, driverArgs, masterEndpoints, conf))