We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 83759af commit 70d80b5Copy full SHA for 70d80b5
lib/fluent/plugin/output.rb
@@ -1214,6 +1214,7 @@ def try_flush
1214
if output.delayed_commit
1215
log.trace "executing delayed write and commit", chunk: dump_unique_id_hex(chunk.unique_id)
1216
@write_count_metrics.inc
1217
+ @write_secondary_count_metrics.inc if using_secondary
1218
@dequeued_chunks_mutex.synchronize do
1219
# delayed_commit_timeout for secondary is configured in <buffer> of primary (<secondary> don't get <buffer>)
1220
@dequeued_chunks << DequeuedChunkInfo.new(chunk.unique_id, Time.now, self.delayed_commit_timeout)
0 commit comments