Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions assemble/bin/accumulo-cluster
Original file line number Diff line number Diff line change
Expand Up @@ -408,9 +408,9 @@ function execute_command() {
servers_per_host="${!S:-1}"

if [[ $ARG_LOCAL == 1 ]]; then
debugOrRunAsync bash -c "ACCUMULO_CLUSTER_ARG=$servers_per_host \"$bin/accumulo-service\" $service $control_cmd -o general.process.bind.addr=$host $*"
debugOrRunAsync bash -c "ACCUMULO_CLUSTER_ARG=$servers_per_host \"$bin/accumulo-service\" $service $control_cmd -o rpc.bind.addr=$host $*"
else
debugOrRunAsync "${SSH[@]}" "$host" "bash -c 'ACCUMULO_CLUSTER_ARG=$servers_per_host \"$bin/accumulo-service\" $service $control_cmd -o general.process.bind.addr=$host $*'"
debugOrRunAsync "${SSH[@]}" "$host" "bash -c 'ACCUMULO_CLUSTER_ARG=$servers_per_host \"$bin/accumulo-service\" $service $control_cmd -o rpc.bind.addr=$host $*'"
fi
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ public List<String> split(String value) {
description = "Overrides configuration set in accumulo.properties (but NOT system-wide config"
+ " set in Zookeeper). This is useful when you have process specific configuration items"
+ " that are one-offs from a shared common configuration. Setting the bind address,"
+ " for example, can be done with the arguments \"-o general.process.bind.addr=127.0.0.1\"."
+ " for example, can be done with the arguments \"-o rpc.bind.addr=127.0.0.1\"."
+ " Expected format: -o <key>=<value> [-o <key>=<value>]")
private List<String> overrides = new ArrayList<>();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -99,17 +99,18 @@ public static void startServer(AbstractServer server, Logger LOG) throws Excepti
private final AtomicBoolean closed = new AtomicBoolean(false);
private final Set<String> monitorMetricExclusions;

@SuppressWarnings("deprecation")
protected AbstractServer(ServerId.Type serverType, ServerOpts opts,
BiFunction<SiteConfiguration,ResourceGroupId,ServerContext> serverContextFactory,
String[] args) {
log = LoggerFactory.getLogger(getClass());
this.applicationName = serverType.name();
opts.parseArgs(applicationName, args);
var siteConfig = opts.getSiteConfiguration();
final String newBindParameter = siteConfig.get(Property.RPC_PROCESS_BIND_ADDRESS);
final String newBindParameter = siteConfig.get(siteConfig
.resolve(Property.RPC_PROCESS_BIND_ADDRESS, Property.GENERAL_PROCESS_BIND_ADDRESS));
// If new bind parameter passed on command line or in file, then use it.
if (newBindParameter != null
&& !newBindParameter.equals(Property.RPC_PROCESS_BIND_ADDRESS.getDefaultValue())) {
if (newBindParameter != null && !newBindParameter.isBlank()) {
this.bindAddress = newBindParameter;
} else {
this.bindAddress = ServerOpts.BIND_ALL_ADDRESSES;
Expand Down
Loading