Skip to content
This repository has been archived by the owner on Oct 23, 2024. It is now read-only.

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Stavros Kontopoulos committed Aug 1, 2017
1 parent d0c094c commit 2c0c70f
Showing 1 changed file with 13 additions and 4 deletions.
17 changes: 13 additions & 4 deletions container/appmaster/runit/service/flink/run
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ function add_if_non_empty() {
}

function add_mesos_configurations() {
add_if_non_empty jobmanager.rpc.address $(hostname -f)
add_if_non_empty jobmanager.rpc.address $(hostname -f)
add_if_non_empty mesos.resourcemanager.framework.role "${FLINK_DISPATCHER_MESOS_ROLE}"
add_if_non_empty mesos.resourcemanager.framework.principal "${FLINK_DISPATCHER_MESOS_PRINCIPAL}"
add_if_non_empty mesos.resourcemanager.framework.secret "${FLINK_DISPATCHER_MESOS_SECRET}"
Expand Down Expand Up @@ -83,17 +83,26 @@ function add_ha_configurations() {
add_if_non_empty high-availability.jobmanager.port "${FLINK_HIGH_AVAILABILITY_JOBMANAGER_PORT}"
add_if_non_empty high-availability.job.delay "${FLINK_HIGH_AVAILABILITY_JOB_DELAY}"
add_if_non_empty high-availability.zookeeper.path.root "${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_ROOT}"
add_if_non_empty high-availability.zookeeper.path.running-registry \
"${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_RUNNING_REGISTRY}"
add_if_non_empty high-availability.zookeeper.path.latch "${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_LEADER_LATCH}"
add_if_non_empty high-availability.zookeeper.path.jobgraphs "${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_JOBGRAPHS}"
add_if_non_empty high-availability.zookeeper.path.leader "${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_LEADER}"
add_if_non_empty high-availability.zookeeper.path.checkpoints "${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_CHECKPOINTS}"
add_if_non_empty high-availability.zookeeper.path.checkpoint-counter "${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_CHECKPOINT_COUNTER}"
add_if_non_empty high-availability.zookeeper.path.mesos-workers "${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_MESOS_WORKERS}"

# used for the client at ha services initiated by the mesos app master runner
add_if_non_empty ghigh-availability.zookeeper.client.session-timeout \
add_if_non_empty high-availability.zookeeper.client.session-timeout \
"${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_CLIENT_SESSION_TIMEOUT}"
add_if_non_empty high-availability.zookeeper.client.connection-timeout \
"${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_CLIENT_CONNECTION_TIMEOUT}"
add_if_non_empty high-availability.zookeeper.client.retry-wait \
"${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_CLIENT_RETRY_WAIT}"
add_if_non_empty high-availability.zookeeper.client.max-retry-attempts \
"${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_CLIENT_MAX_RETRY_ATTEMPTS}"
add_if_non_empty high-availability.zookeeper.path.running-registry \
"${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_PATH_RUNNING_REGISTRY}"
add_if_non_empty high-availability.zookeeper.client.acl \
"${FLINK_HIGH_AVAILABILITY_ZOOKEEPER_CLIENT_ACL}"
fi
}

Expand Down

0 comments on commit 2c0c70f

Please sign in to comment.