My sql table structure is "create table emp (empid int primary key, emp_first varchar, emp_last varchar, emp_dept varchar);"
and my logstash.conf file
input {
jdbc{
jdbc_connection_string => "jdbc:cassandra://localhost:9042/dev"
jdbc_user => "cassandra"
jdbc_password => "cassandra"
jdbc_validate_connection => true
jdbc_driver_library => "/Users/nfrteam/.DbSchema/drivers/Cassandra/cassandrajdbc1.1.jar"
jdbc_driver_class => "com.dbschema.CassandraJdbcDriver"
statement => "SELECT * from dev.test_payload where TIME_STAMP > : sql_last_value AND BUCKET > :sql_last_value"
use_column_value => true
tracking_column => "TIME_STAMP"
tracking_column_type => "numeric"
schedule => "* * * * *"
tags => ["jdbc1"]
}
}
output{
if "jdbc1" in [tags]{
stdout {
codec => "rubydebug"
}
}
}
I'm getting this error" [logstash.inputs.jdbc ] Exception when executing JDBC query {:exception=>#<Sequel::DatabaseError: Java::ComDatastaxDriverCoreExceptions::InvalidQueryException: Only EQ and IN relation are supported on the partition key (unless you use the token() function)>}"