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