Skip to content

Instantly share code, notes, and snippets.

@equinox79
Last active August 29, 2015 13:56
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save equinox79/9131350 to your computer and use it in GitHub Desktop.
Save equinox79/9131350 to your computer and use it in GitHub Desktop.
fluentdのin_sqsプラグインを動かすとここでコケる
def emit(tag, es, chain)
@emit_count += 1
es.each {|time,record|
tc = time / @time_slice_cache_interval // ここでコケる
if @before_tc == tc
key = @before_key
else
@before_tc = tc
key = @time_slicer.call(time)
@before_key = key
end
data = format(tag, time, record)
if @buffer.emit(key, data, chain)
submit_flush
end
}
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment