out_cassandra_driver.rb in fluent-plugin-cassandra-driver-0.0.21

- old
+ new

@@ -37,12 +37,9 @@
       #       supplied string
       self.schema = eval(self.schema)
 
       raise ConfigError, "'Schema' must contain at least one column" if self.schema.keys.length < 1
 
-      # convert data keys from string to array
-      self.data_keys = self.data_keys.split(',')
-
       # split hosts to array
       self.hosts = self.hosts.split(',')
     end
 
     def start