diff --git a/heka/files/lua/common/accumulator.lua b/heka/files/lua/common/accumulator.lua
index 9b01a8f..ac86a0e 100644
--- a/heka/files/lua/common/accumulator.lua
+++ b/heka/files/lua/common/accumulator.lua
@@ -47,7 +47,7 @@
 -- ns: the current timestamp in nanosecond (optional)
 function Accumulator:flush(ns)
     local now = ns or time() * 1e9
-    if #self.buffer > self.flush_count or now - self.last_flush > self.flush_interval then
+    if #self.buffer > self.flush_count or now - self.last_flush > self.flush_interval * 1e9 then
         self.flush_cb(self.buffer)
         self.buffer = {}
         self.last_flush = now
diff --git a/heka/files/toml/filter/sandbox.toml b/heka/files/toml/filter/sandbox.toml
index 9608e52..17de658 100644
--- a/heka/files/toml/filter/sandbox.toml
+++ b/heka/files/toml/filter/sandbox.toml
@@ -16,6 +16,9 @@
 {%- if filter.hostname is defined %}
 hostname = "{{ filter.hostname }}"
 {%- endif %}
+{%- if filter.output_limit is defined %}
+output_limit = {{ filter.output_limit|int }}
+{%- endif %}
 
 {%- if filter.config is defined %}
 [{{ filter_name }}_filter.config]
diff --git a/heka/meta/heka.yml b/heka/meta/heka.yml
index 157d8f8..9f04a8b 100644
--- a/heka/meta/heka.yml
+++ b/heka/meta/heka.yml
@@ -708,10 +708,12 @@
       preserve_data: false
       message_matcher: "Type =~ /ceilometer_samples$/"
       ticker_interval: 1
+      # The default output_limit value (64k) is too low to deal with Ceilometer samples
+      output_limit: 524288
       config:
         time_precision: "{{ ceilometer_collector.influxdb_time_precision }}"
         payload_name: 'sample_data'
-        flush_count: 500
+        flush_count: 200
         bulk_metric_type_matcher: 'ceilometer_samples'
   {%- endif %}
   {%- if ceilometer_collector.sensu_host is defined %}
diff --git a/tests/lua/test_accumulator.lua b/tests/lua/test_accumulator.lua
index 837ffd5..2e2bef6 100644
--- a/tests/lua/test_accumulator.lua
+++ b/tests/lua/test_accumulator.lua
@@ -57,8 +57,10 @@
             assertEquals(#items, 0)
             sentinel = true
         end
-        local accum = accumulator.new(20, 1, test_cb)
+        local accum = accumulator.new(20, 4, test_cb)
         accum:flush((now + 2) * 1e9)
+        assertEquals(sentinel, false)
+        accum:flush((now + 5) * 1e9)
         assertEquals(sentinel, true)
     end