diff --git a/index/storage_cass.go b/index/storage_cass.go index 9ceeb6c7b..514510e0b 100644 --- a/index/storage_cass.go +++ b/index/storage_cass.go @@ -55,8 +55,8 @@ func NewCassStorage() Storage { obj.batch = nil obj.batch_time = time.Now() obj.batch_counter = 0 - obj.cass_time_window_secs = float64(config.GetIntDefault("cassandra_time_window_secs", 15)) - obj.cass_flush_size = config.GetIntDefault("cassandra_max_size_batch", 300) + obj.cass_time_window_secs = float64(config.GetIntDefault("cassandra_time_window_secs", 5)) + obj.cass_flush_size = config.GetIntDefault("cassandra_max_size_batch", 30) return obj }