|
@@ -194,7 +194,8 @@ public class OMFailoverProxyProvider implements
|
|
omProxyInfos.entrySet()) {
|
|
omProxyInfos.entrySet()) {
|
|
count++;
|
|
count++;
|
|
rpcAddress =
|
|
rpcAddress =
|
|
- rpcAddress.append(omProxyInfoSet.getValue().toString());
|
|
|
|
|
|
+ rpcAddress.append(
|
|
|
|
+ omProxyInfoSet.getValue().getDelegationTokenService());
|
|
|
|
|
|
if (omProxyInfos.size() != count) {
|
|
if (omProxyInfos.size() != count) {
|
|
rpcAddress.append(",");
|
|
rpcAddress.append(",");
|