Skip to content

Commit b661555

Browse files
Merge pull request openshift#1567 from richm/fluentd-flush_thread_count
use default of 2 for flush_thread_count
2 parents af1ed20 + 1ad6469 commit b661555

6 files changed

+6
-5
lines changed

fluentd/configs.d/filter-pre-mux-client.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
@type file
1717
path '/var/lib/fluentd/buffer-mux-client'
1818
flush_interval "#{ENV['FORWARD_FLUSH_INTERVAL'] || '5s'}"
19-
flush_thread_count "#{ENV['FORWARD_FLUSH_THREAD_COUNT'] || 1}"
19+
flush_thread_count "#{ENV['FORWARD_FLUSH_THREAD_COUNT'] || 2}"
2020
flush_at_shutdown "#{ENV['FLUSH_AT_SHUTDOWN'] || 'false'}"
2121
queued_chunks_limit_size "#{ENV['BUFFER_QUEUE_LIMIT'] || '1024' }"
2222
chunk_limit_size "#{ENV['BUFFER_SIZE_LIMIT'] || '1m' }"

fluentd/configs.d/openshift/output-es-config.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
@type file
3232
path '/var/lib/fluentd/buffer-output-es-config'
3333
flush_interval "#{ENV['ES_FLUSH_INTERVAL'] || '1s'}"
34-
flush_thread_count "#{ENV['ES_FLUSH_THREAD_COUNT'] || 1}"
34+
flush_thread_count "#{ENV['ES_FLUSH_THREAD_COUNT'] || 2}"
3535
flush_at_shutdown "#{ENV['FLUSH_AT_SHUTDOWN'] || 'false'}"
3636
retry_max_interval "#{ENV['ES_RETRY_WAIT'] || '300'}"
3737
retry_forever true

fluentd/configs.d/openshift/output-es-ops-config.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
@type file
3232
path '/var/lib/fluentd/buffer-output-es-ops-config'
3333
flush_interval "#{ENV['OPS_FLUSH_INTERVAL'] || ENV['ES_FLUSH_INTERVAL'] || '1s'}"
34-
flush_thread_count "#{ENV['OPS_FLUSH_THREAD_COUNT'] || ENV['ES_FLUSH_THREAD_COUNT'] || 1}"
34+
flush_thread_count "#{ENV['OPS_FLUSH_THREAD_COUNT'] || ENV['ES_FLUSH_THREAD_COUNT'] || 2}"
3535
flush_at_shutdown "#{ENV['FLUSH_AT_SHUTDOWN'] || 'false'}"
3636
retry_max_interval "#{ENV['OPS_RETRY_WAIT'] || ENV['ES_RETRY_WAIT'] || '300'}"
3737
retry_forever true

fluentd/configs.d/openshift/output-es-ops-retry.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
@type file
3030
path '/var/lib/fluentd/es-ops-retry'
3131
flush_interval "#{ENV['OPS_FLUSH_INTERVAL'] || ENV['ES_FLUSH_INTERVAL'] || '1s'}"
32-
flush_thread_count "#{ENV['OPS_FLUSH_THREAD_COUNT'] || ENV['ES_FLUSH_THREAD_COUNT'] || 1}"
32+
flush_thread_count "#{ENV['OPS_FLUSH_THREAD_COUNT'] || ENV['ES_FLUSH_THREAD_COUNT'] || 2}"
3333
flush_at_shutdown "#{ENV['FLUSH_AT_SHUTDOWN'] || 'false'}"
3434
retry_max_interval "#{ENV['OPS_RETRY_WAIT'] || ENV['ES_RETRY_WAIT'] || '300'}"
3535
retry_forever true

fluentd/configs.d/openshift/output-es-retry.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
@type file
3030
path '/var/lib/fluentd/es-retry'
3131
flush_interval "#{ENV['ES_FLUSH_INTERVAL'] || '1s'}"
32-
flush_thread_count "#{ENV['ES_FLUSH_THREAD_COUNT'] || 1}"
32+
flush_thread_count "#{ENV['ES_FLUSH_THREAD_COUNT'] || 2}"
3333
flush_at_shutdown "#{ENV['FLUSH_AT_SHUTDOWN'] || 'false'}"
3434
retry_max_interval "#{ENV['ES_RETRY_WAIT'] || '300'}"
3535
retry_forever true

fluentd/configs.d/user/secure-forward.conf

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
# chunk_limit_size "#{ENV['BUFFER_SIZE_LIMIT'] || '1m' }"
1717
# flush_interval "#{ENV['FORWARD_FLUSH_INTERVAL'] || '5s'}"
1818
# flush_at_shutdown "#{ENV['FLUSH_AT_SHUTDOWN'] || 'false'}"
19+
# flush_thread_count "#{ENV['FLUSH_THREAD_COUNT'] || 2}"
1920
# retry_max_interval "#{ENV['FORWARD_RETRY_WAIT'] || '300'}"
2021
# retry_forever true
2122
# # the systemd journald 0.0.8 input plugin will just throw away records if the buffer

0 commit comments

Comments
 (0)