From be2b7698b4e04c34d021b404ccbf48110b330fc3 Mon Sep 17 00:00:00 2001 From: Sam Millar Date: Wed, 13 Nov 2019 17:21:03 +0000 Subject: [PATCH] Reduce batch size (0.1.6) --- fluent-plugin-indicative.gemspec | 2 +- lib/fluent/plugin/out_indicative.rb | 2 +- test/plugin/test_out_indicative.rb | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/fluent-plugin-indicative.gemspec b/fluent-plugin-indicative.gemspec index 7708046..72868df 100755 --- a/fluent-plugin-indicative.gemspec +++ b/fluent-plugin-indicative.gemspec @@ -3,7 +3,7 @@ $:.push File.expand_path("../lib", __FILE__) Gem::Specification.new do |s| s.name = "fluent-plugin-indicative" - s.version = "0.1.5" + s.version = "0.1.6" s.authors = ["Sam Millar"] s.email = ["sam@millar.io"] s.homepage = "https://github.com/millar/fluent-plugin-indicative" diff --git a/lib/fluent/plugin/out_indicative.rb b/lib/fluent/plugin/out_indicative.rb index 6fece86..d7d38df 100755 --- a/lib/fluent/plugin/out_indicative.rb +++ b/lib/fluent/plugin/out_indicative.rb @@ -5,7 +5,7 @@ require 'fluent/plugin/output' -BATCH_SIZE = 100 +BATCH_SIZE = 15 def flatten_hash(hash) diff --git a/test/plugin/test_out_indicative.rb b/test/plugin/test_out_indicative.rb index cd4098f..79f27c4 100755 --- a/test/plugin/test_out_indicative.rb +++ b/test/plugin/test_out_indicative.rb @@ -69,7 +69,7 @@ def test_emit_buffer d = create_driver(BUFFER_CONFIG) stub_request(:any, d.instance.api_url) d.run(default_tag: 'test') do - 20.times do + 5.times do d.feed({'event_name' => 'screen_view', 'created_at' => '2015-01-01T10:00:00.000Z', 'session_id' => 'a3bd2', 'user_id' => nil, 'screen' => {'id' => 'index'}}) end end