Skip to content

Agitator bug fixes/improvments #321

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
DomGarguilo merged 1 commit into from
Sep 22, 2026
+16 −15
Merged

Agitator bug fixes/improvments #321

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
5 changes: 3 additions & 2 deletions bin/agitator
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,8 @@

bin_dir=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
at_home=$(cd "$(dirname "$bin_dir")" && pwd)
source "${bin_dir}/build"
# only 'start' needs env.sh, which exits if the install paths are missing
[[ $1 == stop ]] || source "${bin_dir}/build"

function print_usage() {
cat <<EOF
Expand Down Expand Up @@ -50,7 +51,7 @@ function start_app_agitator() {
local node_to_kill
nodes_to_kill_array=()
local T
local ENV_VARS="ACCUMULO_HOME=$ACCUMULO_HOME ZOOKEEPER_HOME=$ZOOKEEPER_HOME HADOOP_HOME=$HADOOP_HOME JAVA_HOME=$JAVA_HOME"
local ENV_VARS="ACCUMULO_HOME=$ACCUMULO_HOME ZOOKEEPER_HOME=$ZOOKEEPER_HOME HADOOP_HOME=$HADOOP_HOME HADOOP_CONF_DIR=$HADOOP_CONF_DIR HADOOP_LOG_DIR=$HADOOP_LOG_DIR JAVA_HOME=$JAVA_HOME"

if ((num_hosts == 0)); then
echo "ERROR: No hosts were found in env for $app_name"
Expand Down
26 changes: 13 additions & 13 deletions conf/env.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -92,29 +92,29 @@ fi
AGTR_ACCUMULO_USER=$(whoami)
export AGTR_ACCUMULO_USER
# Time (in minutes) between killing Accumulo managers
export AGTR_MANAGER_KILL_SLEEP_TIME=60
export AGTR_MANAGER_RESTART_SLEEP_TIME=2
export AGTR_MANAGER_KILL_SLEEP_TIME="${AGTR_MANAGER_KILL_SLEEP_TIME:-60}"
export AGTR_MANAGER_RESTART_SLEEP_TIME="${AGTR_MANAGER_RESTART_SLEEP_TIME:-2}"
# Time (in minutes) between killing Accumulo tservers
export AGTR_TSERVER_KILL_SLEEP_TIME=20
export AGTR_TSERVER_RESTART_SLEEP_TIME=10
export AGTR_TSERVER_KILL_SLEEP_TIME="${AGTR_TSERVER_KILL_SLEEP_TIME:-20}"
export AGTR_TSERVER_RESTART_SLEEP_TIME="${AGTR_TSERVER_RESTART_SLEEP_TIME:-10}"
# Min and max number of Accumulo tservers that the agitator will kill at once
export AGTR_TSERVER_MIN_KILL=1
export AGTR_TSERVER_MAX_KILL=1
export AGTR_TSERVER_MIN_KILL="${AGTR_TSERVER_MIN_KILL:-1}"
export AGTR_TSERVER_MAX_KILL="${AGTR_TSERVER_MAX_KILL:-1}"
# Amount of time (in minutes) the agitator should sleep before killing datanodes
export AGTR_DATANODE_KILL_SLEEP_TIME=20
export AGTR_DATANODE_KILL_SLEEP_TIME="${AGTR_DATANODE_KILL_SLEEP_TIME:-20}"
# Amount of time (in minutes) the agitator should wait before restarting datanodes
export AGTR_DATANODE_RESTART_SLEEP_TIME=10
export AGTR_DATANODE_RESTART_SLEEP_TIME="${AGTR_DATANODE_RESTART_SLEEP_TIME:-10}"
# Min and max number of datanodes the agitator will kill at once
export AGTR_DATANODE_MIN_KILL=1
export AGTR_DATANODE_MAX_KILL=1
export AGTR_DATANODE_MIN_KILL="${AGTR_DATANODE_MIN_KILL:-1}"
export AGTR_DATANODE_MAX_KILL="${AGTR_DATANODE_MAX_KILL:-1}"
# Datanode hosts if different from tservers
#export AGTR_DATANODE_HOSTS="host1 host2"
# HDFS agitation
AGTR_HDFS_USER=$(whoami)
export AGTR_HDFS_USER
export AGTR_HDFS=false
export AGTR_HDFS_SLEEP_TIME=10
export AGTR_HDFS_SUPERUSER=hdfs
export AGTR_HDFS="${AGTR_HDFS:-false}"
export AGTR_HDFS_SLEEP_TIME="${AGTR_HDFS_SLEEP_TIME:-10}"
export AGTR_HDFS_SUPERUSER="${AGTR_HDFS_SUPERUSER:-hdfs}"
export AGTR_HDFS_COMMAND="${HADOOP_HOME}/bin/hdfs"
AGTR_HDFS_SUDO=$(command -v sudo)
export AGTR_HDFS_SUDO
Loading