@Test public void derivedJobMasterAddressesFromMasterAddresses() { ServerConfiguration.set(PropertyKey.MASTER_EMBEDDED_JOURNAL_ADDRESSES, "host1:10,host2:20,host3:10"); ServerConfiguration.set(PropertyKey.MASTER_HOSTNAME, "host1"); ServerConfiguration.set(PropertyKey.JOB_MASTER_EMBEDDED_JOURNAL_PORT, 5); RaftJournalConfiguration conf = getConf(ServiceType.JOB_MASTER_RAFT); assertEquals(Sets.newHashSet(InetSocketAddress.createUnresolved("host1", 5), InetSocketAddress.createUnresolved("host2", 5), InetSocketAddress.createUnresolved("host3", 5)), new HashSet<>(conf.getClusterAddresses())); }
public List<InetSocketAddress> getClusterAddresses() { return mClusterAddresses; }
RaftJournalConfiguration { public List<InetSocketAddress> getClusterAddresses() { return mClusterAddresses; } }
RaftJournalConfiguration { public List<InetSocketAddress> getClusterAddresses() { return mClusterAddresses; }  }
RaftJournalConfiguration { public List<InetSocketAddress> getClusterAddresses() { return mClusterAddresses; }  static RaftJournalConfiguration defaults(ServiceType serviceType); void validate(); List<InetSocketAddress> getClusterAddresses(); long getElectionTimeoutMs(); long getHeartbeatIntervalMs(); InetSocketAddress getLocalAddress(); InetSocketAddress getProxyAddress(); long getMaxLogSize(); File getPath(); RaftJournalConfiguration setClusterAddresses(List<InetSocketAddress> clusterAddresses); RaftJournalConfiguration setElectionTimeoutMs(long electionTimeoutMs); RaftJournalConfiguration setHeartbeatIntervalMs(long heartbeatIntervalMs); RaftJournalConfiguration setLocalAddress(InetSocketAddress localAddress); RaftJournalConfiguration setMaxLogSize(long maxLogSize); RaftJournalConfiguration setPath(File path); }
RaftJournalConfiguration { public List<InetSocketAddress> getClusterAddresses() { return mClusterAddresses; }  static RaftJournalConfiguration defaults(ServiceType serviceType); void validate(); List<InetSocketAddress> getClusterAddresses(); long getElectionTimeoutMs(); long getHeartbeatIntervalMs(); InetSocketAddress getLocalAddress(); InetSocketAddress getProxyAddress(); long getMaxLogSize(); File getPath(); RaftJournalConfiguration setClusterAddresses(List<InetSocketAddress> clusterAddresses); RaftJournalConfiguration setElectionTimeoutMs(long electionTimeoutMs); RaftJournalConfiguration setHeartbeatIntervalMs(long heartbeatIntervalMs); RaftJournalConfiguration setLocalAddress(InetSocketAddress localAddress); RaftJournalConfiguration setMaxLogSize(long maxLogSize); RaftJournalConfiguration setPath(File path);  }