@@ -63,7 +63,7 @@ function install_deps() {
63
63
64
64
if [ ! -f statsd-jvm-profiler-2.1.0-shaded.jar ]; then
65
65
echo -e " [$( date -Ins) ] Shading possibly conflicing Java packages in statsd-jvm-profiler.jar"
66
- cat<< EOF>jarjar-rules.txt
66
+ cat << EOF >jarjar-rules.txt
67
67
rule com.timgroup.** com.timgroup.sparkflamegraph.@1
68
68
rule com.google.guava.** com.google.guava.sparkflamegraph.@1
69
69
rule org.influxdb.** org.influxdb.sparkflamegraph.@1
@@ -108,10 +108,10 @@ EOF
108
108
exit 1
109
109
fi
110
110
111
- curl -sS -X POST $influx_uri /query \
111
+ curl -fsS -X POST $influx_uri /query \
112
112
--data-urlencode " q=CREATE DATABASE profiler" > /dev/null
113
113
114
- curl -sS -X POST $influx_uri /query \
114
+ curl -fsS -X POST $influx_uri /query \
115
115
--data-urlencode " q=CREATE USER profiler WITH PASSWORD 'profiler' WITH ALL PRIVILEGES" > /dev/null
116
116
}
117
117
@@ -182,14 +182,14 @@ username=profiler,password=profiler,prefix=sparkapp,tagMapping=spark")
182
182
183
183
function generate_flamegraph() {
184
184
rm -rf stack_traces
185
- echo -e "[$( date -Ins) ] Collecting metrics"
185
+ echo -e " [$( date -Ins) ] Collecting profiling metrics"
186
186
187
187
python2.7 $install_dir /influxdb_dump.py \
188
188
-o $local_ip -r $influx_http_port -u profiler \
189
189
-p profiler -d profiler -t spark -e sparkapp -x stack_traces > /dev/null 2>&1 && :
190
190
191
191
if [ $? -ne 0 ]; then
192
- echo -e "[$( date -Ins) ] No metrics were recorded!"
192
+ echo -e " [$( date -Ins) ] No profiling metrics were recorded!"
193
193
return 0
194
194
fi
195
195
0 commit comments