Skip to content

Commit

Permalink
Minor tweaks to logstash workers and pipeline size to be a little mor…
Browse files Browse the repository at this point in the history
…e conservative to avoid logstash crashes due to heap issues
  • Loading branch information
mmguero committed Mar 17, 2022
1 parent 1678272 commit fd8adb9
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
4 changes: 2 additions & 2 deletions docker-compose-standalone.yml
Original file line number Diff line number Diff line change
Expand Up @@ -98,8 +98,8 @@ x-dashboards-helper-variables: &dashboards-helper-variables
ISM_SNAPSHOT_REPO : 'logs'

x-logstash-variables: &logstash-variables
pipeline.workers : 4
pipeline.batch.size : 100
pipeline.workers : 3
pipeline.batch.size : 75
pipeline.batch.delay : 50
LOGSTASH_OUI_LOOKUP : 'true'
LOGSTASH_SEVERITY_SCORING : 'true'
Expand Down
4 changes: 2 additions & 2 deletions docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -98,8 +98,8 @@ x-dashboards-helper-variables: &dashboards-helper-variables
ISM_SNAPSHOT_REPO : 'logs'

x-logstash-variables: &logstash-variables
pipeline.workers : 4
pipeline.batch.size : 100
pipeline.workers : 3
pipeline.batch.size : 75
pipeline.batch.delay : 50
LOGSTASH_OUI_LOOKUP : 'true'
LOGSTASH_SEVERITY_SCORING : 'true'
Expand Down
6 changes: 3 additions & 3 deletions scripts/install.py
Original file line number Diff line number Diff line change
Expand Up @@ -303,11 +303,11 @@ def tweak_malcolm_runtime(
# - https://www.elastic.co/guide/en/logstash/current/multiple-pipelines.html
# we don't want it too high, as in Malcolm Logstash also competes with OpenSearch, etc. for resources
if self.totalCores > 16:
lsWorkers = 12
lsWorkers = 10
elif self.totalCores >= 12:
lsWorkers = 8
lsWorkers = 6
else:
lsWorkers = 4
lsWorkers = 3

while not InstallerYesOrNo(
f'Setting {osMemory} for OpenSearch and {lsMemory} for Logstash. Is this OK?', default=True
Expand Down

0 comments on commit fd8adb9

Please sign in to comment.