lib/logstash/outputs/charrington/create_redshift_table.rb in logstash-output-charrington-0.3.1 vs lib/logstash/outputs/charrington/create_redshift_table.rb in logstash-output-charrington-0.3.2

- old
+ new

@@ -73,12 +73,10 @@ def create_table execute("CREATE TABLE IF NOT EXISTS #{schema}#{table_name} (#{column_types.join(', ')}) diststyle key sortkey(received_at)") end def execute(sql) - puts "CREATE SQL #{sql}" statement = connection.prepareStatement( sql.gsub(/\s+/, " ").strip ) - puts "CREATE SQL #{sql}" statement.execute() rescue Java::JavaSql::SQLException => e puts "Redshift SQLException: #{e.message}" ensure statement.close unless statement.nil?