lib/fluent/plugin/out_cassandra_driver.rb in fluent-plugin-cassandra-driver-0.0.8 vs lib/fluent/plugin/out_cassandra_driver.rb in fluent-plugin-cassandra-driver-0.0.9

- old
+ new

@@ -64,9 +64,11 @@ values = build_insert_values_string(self.schema.keys, self.data_keys, record, self.pop_data_keys) cql = "INSERT INTO #{self.columnfamily} (#{self.schema.keys.join(',')}) VALUES (#{values}) USING TTL #{self.ttl}" + $log.debug "CQL query: #{cql}" + begin @session.execute(cql) rescue Exception => e $log.error "Cannot send record to Cassandra: #{e.message}\nTrace: #{e.backtrace.to_s}" end